Method: Async::LimitedQueue#initialize

Defined in:
lib/async/queue.rb

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

Returns a new instance of LimitedQueue.



66
67
68
69
70
71
72
 
# File 'lib/async/queue.rb', line 66

def initialize(limit = 1, **options)
  super(**options)
  
  @limit = limit
  
  @full = Notification.new
end