} if (!
$pushedResponse) { $ch =
curl_init();
$this->logger?->
info(sprintf('Request: "%s %s"',
$method,
$url));
$curlopts +=
[\CURLOPT_SHARE =>
$this->multi->share
];
} foreach ($curlopts as $opt =>
$value) { if (null !==
$value && !
curl_setopt($ch,
$opt,
$value) && \CURLOPT_CERTINFO !==
$opt && (!\
defined('CURLOPT_HEADEROPT'
) || \CURLOPT_HEADEROPT !==
$opt)) { $constantName =
$this->
findConstantName($opt);
throw new TransportException(sprintf('Curl option "%s" is not supported.',
$constantName ??
$opt));
} } return $pushedResponse ??
new CurlResponse($this->multi,
$ch,
$options,
$this->logger,
$method, self::
createRedirectResolver($options,
$host,
$port), CurlClientState::
$curlVersion['version_number'
],
$url);
} public function stream(ResponseInterface|iterable
$responses, float
$timeout = null
): ResponseStreamInterface
{ if ($responses instanceof CurlResponse
) { $responses =
[$responses];
}