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

def stream(task)
	task.annotate("Streaming #{@body} to #{@stream}.")
	
	input = @stream.wait_for_input
	
	@body.call(Body::Stream.new(input, self))
rescue Async::Stop
	# Ignore.
end