Method: Kraps::TimeoutQueue#deq

Defined in:
lib/kraps/timeout_queue.rb

#deq(timeout:) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/kraps/timeout_queue.rb', line 19

def deq(timeout:)
  synchronize do
    @cond.wait(timeout) if @queue.empty?

    return @queue.empty? ? nil : @queue.shift
  end
end