class Async::HTTP::Protocol::HTTP1::Client

def call(request, task: Task.current)
	Async.logger.debug(self) {"#{request.method} #{request.path} #{request.headers.inspect}"}
	
	# We carefully interpret https://tools.ietf.org/html/rfc7230#section-6.3.1 to implement this correctly.
	begin
		self.write_request(request.authority, request.method, request.path, self.version, request.headers)
	rescue
		# If we fail to fully write the request and body, we can retry this request.
		raise RequestFailed.new
	end
	
	if request.body?
		task.async do
			# Once we start writing the body, we can't recover if the request fails. That's because the body might be generated dynamically, streaming, etc.
			self.write_body(request.body)
		end
	else
		self.write_empty_body(request.body)
	end
	
	# This won't return the response until the entire body is written.
	return Response.new(self, request)
rescue
	# This will ensure that #reusable? returns false.
	@stream.close
	
	raise
end