class Async::HTTP::Body::Pipe

def reader(task)
	@reader = task
	
	task.annotate "#{self.class} reader."
	
	while chunk = @input.read
		@head.write(chunk)
		@head.flush
	end
	
	@head.close_write
ensure
	@input.close($!)
	
	close_head if @writer&.finished?
end