class Protocol::HTTP::Body::Streamable::Body

def read
	# We are reading chunk by chunk, allocate an output stream and execute the block to generate the chunks:
	if @output.nil?
		if @block.nil?
			raise ConsumedError, "Streaming body has already been consumed!"
		end
		
		@output = Output.schedule(@input, @block)
		@block = nil
	end
	
	@output.read
end