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

def stream(task)
	task.annotate("Streaming #{@body} to #{@stream}.")
	
	input = @stream.wait_for_input
	stream = ::Protocol::HTTP::Body::Stream.new(input, self)
	
	@body.call(stream)
rescue => error
	self.close(error)
	raise
end