class Async::HTTP::Protocol::HTTP11

def read_body(headers)
	if headers[:transfer_encoding] == 'chunked'
		buffer = Async::IO::BinaryString.new
		
		while true
			size = read_line.to_i(16)
			
			if size == 0
				read_line
				break
			end
			
			buffer << @stream.read(size)
			
			read_line # Consume the trailing CRLF
		end
		
		return buffer
	elsif content_length = headers[:content_length]
		return @stream.read(Integer(content_length))
	end
end