$maxHostConnections = 0 <
$this->maxHostConnections ?
$this->maxHostConnections : \PHP_INT_MAX;
$pool =
new DefaultConnectionFactory($connector,
$context);
$pool = ConnectionLimitingPool::
byAuthority($maxHostConnections,
$pool);
return $this->clients
[$key] =
[($this->clientConfigurator
)(new PooledHttpClient($pool)),
$handleConnector];
} private function handlePush(Request
$request, Promise
$response, array
$options): Promise
{ $deferred =
new Deferred();
$authority =
$request->
getUri()->
getAuthority();
if ($this->maxPendingPushes <= \
count($this->pushedResponses
[$authority] ??
[])) { $fifoUrl =
key($this->pushedResponses
[$authority]);
unset($this->pushedResponses
[$authority][$fifoUrl]);
$this->logger?->
debug(sprintf('Evicting oldest pushed response: "%s"',
$fifoUrl));
} $url =
(string) $request->
getUri();
$this->logger?->
debug(sprintf('Queueing pushed response: "%s"',
$url));
$this->pushedResponses
[$authority][] =
[$url,
$deferred,
$request,
$response,
[