Remove useless yield. Fixes #39.

Author: ioquatix

lib/async/redis/context/pipeline.rb

@@ -46,6 +46,10 @@ def flush(count = 0)
 					end
 				end
 
+				def collect
+					@count.times.map{read_response}
+				end
+				
 				def sync
 					@sync ||= Sync.new(self)
 				end
@@ -73,12 +77,6 @@ def read_response
 					end
 				end
 
-				def collect
-					yield
-					
-					@count.times.map{read_response}
-				end
-				
 				def close
 					flush
 				ensure

test/async/redis/context/pipeline.rb

@@ -20,7 +20,7 @@
 		{pipeline_key_1: '123', pipeline_key_2: '456'}
 	end
 
-	describe '.call' do
+	with '#call' do
 		it 'accumulates commands without running them' do
 			pairs.each do |key, value|
 				pipeline.call('SET', key, value)
@@ -31,8 +31,26 @@
 			pairs.each do |key, value|
 				expect(client.get(key)).to be == value
 			end
-			
+		ensure
 			client.close
 		end
 	end
+	
+	with '#collect' do
+		it 'accumulates commands and runs them' do
+			pairs.each do |key, value|
+				pipeline.call('SET', key, value)
+			end
+			
+			pipeline.flush
+			
+			pairs.each do |key, value|
+				pipeline.call('GET', key)
+			end
+			
+			expect(pipeline.collect).to be == pairs.values
+		ensure
+			pipeline.close
+		end
+	end
 end