class Async::HTTP::Body::Hijack

def read
	unless @task
		@stream = Stream.new(@input)
		
		@task = Task.current.async do |task|
			task.annotate "Streaming hijacked body."
			
			@block.call(@stream)
		end
	end
	
	return @stream.output.read
end