Ensure input and output is closed appropriately on error.

Author: ioquatix

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

@@ -83,6 +83,7 @@ def stream(task)
 						@body.call(stream)
 					rescue => error
 						self.close(error)
+						raise
 					end
 
 					# Reads chunks from the given body and writes them to the stream as fast as possible.