lib/proco/queue/multi_queue.rb in proco-0.0.1 vs lib/proco/queue/multi_queue.rb in proco-0.0.2
- old
+ new
@@ -2,10 +2,10 @@
class Proco
module Queue
# @private
class MultiQueue < Proco::Queue::Base
- def initialize size
+ def initialize size, delay
super
@future = Future.new
end
def push_impl item