lib/jugglite/deferrable_body.rb in jugglite-0.0.1.alpha vs lib/jugglite/deferrable_body.rb in jugglite-0.0.2.alpha
- old
+ new
@@ -8,10 +8,10 @@
def write(body)
@queue.push(body)
end
- def each &blk
+ def each(&blk)
@body_callback = blk
processor = proc { |item|
@body_callback.call(item)
@queue.pop(&processor)
}