class Semian::ThreadSafe::SlidingWindow

def initialize(**)
  super
  @lock = Mutex.new
end

def push(*)
  @lock.synchronize { super }
end

def reject!(*)
  @lock.synchronize { super }
end