WIP

gems.rb

@@ -10,7 +10,7 @@
 # gem "async", path: "../async"
 # gem "traces", path: "../traces"
 # gem "io-endpoint", path: "../io-endpoint"
-gem "sus-fixtures-async-http", path: "../sus-fixtures-async-http"
+# gem "sus-fixtures-async-http", path: "../sus-fixtures-async-http"
 
 # gem "protocol-http", path: "../protocol-http"
 # gem "protocol-http1", path: "../protocol-http1"
@@ -29,7 +29,7 @@
 	gem "covered"
 	gem "sus"
 	gem "sus-fixtures-async"
-	# gem "sus-fixtures-async-http", "~> 0.7"
+	gem "sus-fixtures-async-http", "~> 0.8"
 	gem "sus-fixtures-openssl"
 
 	gem "bake"

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

@@ -64,7 +64,7 @@ def call(request, task: Task.current)
 						@ready = true
 
 						return response
-					rescue => error
+					rescue
 						# This will ensure that #reusable? returns false.
 						@stream.close
 

test/async/http/proxy.rb

@@ -68,8 +68,9 @@
 			Protocol::HTTP::Middleware.for do |request|
 				expect(request.path).to be == "localhost:1"
 
+				Console.debug(self) {"Hijacking incoming request..."}
 				Async::HTTP::Body::Hijack.response(request, 200, {}) do |stream|
-					while chunk = stream.readpartial(1024)
+					while chunk = (stream.readpartial(1024) rescue nil)
 						stream.write(chunk)
 						stream.flush
 					end
@@ -86,6 +87,7 @@
 			expect(proxy.client.pool).to be(:empty?)
 
 			proxy.connect do |peer|
+				binding.irb
 				peer.write(data)
 				peer.close_write
 
@@ -124,7 +126,7 @@
 				end
 
 				host, port = request.path.split(":", 2)
-				endpoint = Async::IO::Endpoint.tcp(host, port)
+				endpoint = ::IO::Endpoint.tcp(host, port)
 
 				Console.logger.debug(self) {"Making connection to #{endpoint}..."}
 
@@ -135,7 +137,8 @@
 					reader = Async do |task|
 						task.annotate "Upstream reader."
 
-						while chunk = upstream.readpartial(1024)
+						while chunk = (upstream.readpartial(1024) rescue nil)
+							Console.logger.info(self) {"Read #{chunk.bytesize} bytes from upstream..."}
 							stream.write(chunk)
 							stream.flush
 						end
@@ -147,7 +150,8 @@
 					writer = Async do |task|
 						task.annotate "Upstream writer."
 
-						while chunk = stream.readpartial(1024)
+						while chunk = (stream.readpartial(1024) rescue nil)
+							Console.logger.info(self) {"Read #{chunk.bytesize} bytes from downstream..."}
 							upstream.write(chunk)
 							upstream.flush
 						end