Minor fixes.

Author: ioquatix

async-http.gemspec

@@ -29,7 +29,7 @@ Gem::Specification.new do |spec|
 	spec.add_dependency "io-endpoint", "~> 0.11"
 	spec.add_dependency "io-stream", "~> 0.4"
 	spec.add_dependency "protocol-http", "~> 0.37"
-	spec.add_dependency "protocol-http1", "~> 0.25"
-	spec.add_dependency "protocol-http2", "~> 0.18"
+	spec.add_dependency "protocol-http1", "~> 0.27"
+	spec.add_dependency "protocol-http2", "~> 0.19"
 	spec.add_dependency "traces", ">= 0.10"
 end

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

@@ -18,11 +18,12 @@ def initialize(...)
 
 					attr_accessor :pool
 
-					def closed!
+					def closed(error = nil)
 						super
 
 						if pool = @pool
 							@pool = nil
+							# If the connection is not reusable, this will retire it from the connection pool and invoke `#close`.
 							pool.release(self)
 						end
 					end
@@ -73,13 +74,9 @@ def call(request, task: Task.current)
 							write_body(@version, request.body, false, trailer)
 						end
 
-						response = Response.read(self, request)
-						
-						return response
+						return Response.read(self, request)
 					rescue => error
-						# This will ensure that #reusable? returns false.
 						self.close(error)
-						
 						raise
 					end
 				end

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

@@ -43,6 +43,8 @@ def http2?
 
 					def read_line?
 						@stream.read_until(CRLF)
+					rescue Errno::ECONNRESET
+						return nil
 					end
 
 					def read_line

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

@@ -22,7 +22,7 @@ def initialize(...)
 						@ready = Async::Notification.new
 					end
 
-					def closed!
+					def closed(error = nil)
 						super
 
 						@ready.signal

test/async/http/proxy.rb

@@ -153,8 +153,6 @@
 							upstream.write(chunk)
 							upstream.flush
 						end
-					rescue Async::Wrapper::Cancelled
-						#ignore
 					ensure
 						Console.logger.debug(self) {"Finished writing to upstream..."}
 						upstream.close_write