If a block is given, flush and yield.

Author: ioquatix

lib/async/redis/context/pipeline.rb

@@ -47,6 +47,11 @@ def flush(count = 0)
 				end
 
 				def collect
+					if block_given?
+						flush
+						yield
+					end
+					
 					@count.times.map{read_response}
 				end