Method: Async::LimitedQueue#initialize

Defined in:
lib/async/queue.rb

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

Returns a new instance of LimitedQueue.



79
80
81
82
83
84
85
 
# File 'lib/async/queue.rb', line 79

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