class Async::HTTP::Protocol::HTTP11

def read_body(headers)
	if headers['transfer-encoding'] == 'chunked'
		return Body::Chunked.new(self)
	elsif content_length = headers['content-length']
		return Body::Fixed.new(@stream, Integer(content_length))
	end
end