Ensure input and output is closed appropriately on error.

Author: ioquatix

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

@@ -72,8 +72,11 @@ def stream(task)
 						input = @stream.wait_for_input
 
 						@body.call(::Protocol::HTTP::Body::Stream.new(input, self))
-					rescue Async::Stop
-						# Ignore.
+					rescue => error
+						raise
+					ensure
+						input.close(error)
+						self.close(error)
 					end
 
 					# Reads chunks from the given body and writes them to the stream as fast as possible.
@@ -86,11 +89,13 @@ def passthrough(task)
 							# chunk.clear unless chunk.frozen?
 							# GC.start
 						end
-						
-						self.close
+					rescue => error
+						raise
 					ensure
-						@body&.close($!)
+						@body&.close(error)
 						@body = nil
+						
+						self.close(error)
 					end
 
 					# Send `maximum_size` bytes of data using the specified `stream`. If the buffer has no more chunks, `END_STREAM` will be sent on the final chunk.