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