class Async::HTTP::Protocol::HTTP2::Stream::Output

def passthrough(task)

Reads chunks from the given body and writes them to the stream as fast as possible. 
def passthrough(task)
	task.annotate("Writing #{@body} to #{@stream}.")
	
	while chunk = @body&.read
		self.write(chunk)
	end
	
	self.close_write
rescue Async::Stop
	# Ignore.
ensure
	@body&.close($!)
	@body = nil
end