Method: Async::LimitedQueue#initialize

Defined in:
lib/async/queue.rb

#initialize(limit = 1, **options) ⇒ LimitedQueue

Create a new limited queue.



141
142
143
 
# File 'lib/async/queue.rb', line 141

def initialize(limit = 1, **options)
  super(**options, delegate: Thread::SizedQueue.new(limit))
end