Implement response info in streaming API. (#48)

Author: ebababi

lib/async/http/faraday/adapter.rb

@@ -179,19 +179,19 @@ def perform_request(env)
 								response = env.stream_response do |&on_data|
 									response = client.call(request)
 
+									save_response(env, response.status, nil, response.headers, finished: false)
+									
 									response.each do |chunk|
 										on_data.call(chunk)
 									end
 
 									response
 								end
-								
-								save_response(env, response.status, nil, response.headers)
 							else
 								response = client.call(request)
-								
-								save_response(env, response.status, encoded_body(response), response.headers)
 							end
+							
+							save_response(env, response.status, encoded_body(response), response.headers)
 						end
 					end
 

test/async/http/faraday/adapter.rb

@@ -198,16 +198,20 @@ def get_response(url = bound_url, path = '/index', adapter_options: {})
 					builder.adapter :async_http
 				end
 
-				chunks = []
+				streamed = []
+				env = nil
 
 				response = client.get(bound_url) do |request|
-					request.options.on_data = proc do |chunk|
-						chunks << chunk
+					request.options.on_data = proc do |chunk, size, block_env|
+						streamed << [chunk, size]
+						env ||= block_env
 					end
 				end
 
-				expect(response.body).to be_nil
-				expect(chunks).to be == ["chunk0", "chunk1", "chunk2"]
+				expect(response.body).to be(:empty?)
+				expect(streamed).to be == [["chunk0", 6], ["chunk1", 12], ["chunk2", 18]]
+				expect(env).to be_a(Faraday::Env)
+				expect(env.status).to be == 200
 			end
 		end
 	end