class Async::HTTP::Protocol::HTTP11

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