lib/proco/queue/batch_queue.rb in proco-0.0.1 vs lib/proco/queue/batch_queue.rb in proco-0.0.2
- old
+ new
@@ -2,11 +2,11 @@
class Proco
module Queue
# @private
class BatchQueue < Proco::Queue::Base
- def initialize size, batch_size
- super size
+ def initialize size, batch_size, delay
+ super size, delay
@futures = []
@batch_size = batch_size
end
def push_impl item