class Async::HTTP::Protocol::HTTP11

def read_body(headers)
	if chunked?(headers)
		return Body::Chunked.new(self)
	elsif content_length = headers[CONTENT_LENGTH]
		if content_length != 0
			return Body::Fixed.new(@stream, Integer(content_length))
		end
	end
end