Extra debugging.

Author: ioquatix

examples/many/client.rb

@@ -0,0 +1,44 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+require 'async'
+require 'async/http/internet'
+
+def get_responses_using_fibers(count)
+	puts("Getting #{count} responses using fibers.")
+	url = "https://httpbin.org/delay/0.001"
+	responses = []
+
+	Async do
+		puts("Starting Async block.")
+		begin
+			internet = Async::HTTP::Internet.new
+			response_count = 0
+			count.times do
+				Async do
+					begin
+						response = internet.get(url)
+						response_count += 1
+						puts("Response count: #{response_count}. Received response: #{response.status}")
+						responses << response.status
+					rescue => e
+						puts("Error during request: #{e.message}")
+					# ensure
+					# 	response&.finish
+					end
+				end
+			end
+		rescue => e
+			puts("Error during outer: #{e.message}")
+		ensure
+			internet&.close
+		end
+	end.wait
+
+	puts("Ending Async block.")
+	responses
+end
+
+count = ARGV.first ? ARGV.first.to_i : 129
+get_responses_using_fibers(count)
+puts('Done.')

fixtures/async/http/a_protocol.rb

@@ -501,15 +501,23 @@ module HTTP
 			with 'slow server' do
 				let(:app) do
 					::Protocol::HTTP::Middleware.for do |request|
+						$stderr.puts "Sleeping for #{endpoint.timeout * 2} seconds..."
 						sleep(endpoint.timeout * 2)
+						$stderr.puts "Sending response..."
 						::Protocol::HTTP::Response[200, {}, []]
 					end
 				end
 
 				it "can't get /" do
 					expect do
-						client.get("/")
+						response = client.get("/")
+						$stderr.puts "Response: #{response.inspect}"
+					ensure
+						$stderr.puts "Closing response..."
+						response&.close
 					end.to raise_exception(::IO::TimeoutError)
+					
+					$stderr.puts "Test is done..."
 				end
 			end
 

lib/async/http/protocol/http1/server.rb

@@ -68,7 +68,8 @@ def each(task: Task.current)
 										stream = write_upgrade_body(protocol)
 
 										# At this point, the request body is hijacked, so we don't want to call #finish below.
-										request = response = nil
+										request = nil unless request.body
+										response = nil
 
 										body.call(stream)
 									else
@@ -78,15 +79,17 @@ def each(task: Task.current)
 											stream = write_tunnel_body(request.version)
 
 											# Same as above:
-											request = response = nil
+											request = nil unless request.body
+											response = nil
 
 											body.call(stream)
 										else
 											head = request.head?
 											version = request.version
 
 											# Same as above:
-											request = response = nil
+											request = nil unless request.body
+											response = nil
 
 											write_body(version, body, head, trailer)
 										end

lib/async/http/protocol/http2/client.rb

@@ -35,6 +35,7 @@ def call(request)
 
 						response = create_response
 						response.send_request(request)
+						$stderr.puts "Waiting for response..."
 						response.wait
 
 						return response

lib/async/http/protocol/http2/response.rb

@@ -123,7 +123,7 @@ def closed(error)
 
 							@exception = error
 
-							notify!
+							self.notify!
 						end
 					end