$this->initializer =
static function Dself
$response) { $waitFor =
curl_getinfo($response->handle, \CURLINFO_PRIVATE
);
return 'H' ===
$waitFor[0
];
};
// Schedule the request in a non-blocking way
$multi->lastTimeout = null;
$multi->openHandles
[$id] =
[$ch,
$options];
curl_multi_add_handle($multi->handle,
$ch);
$this->canary =
new Canary(static function D
) use ($ch,
$multi,
$id) { unset($multi->pauseExpiries
[$id],
$multi->openHandles
[$id],
$multi->handlesActivity
[$id]);
curl_setopt($ch, \CURLOPT_PRIVATE, '_0'
);
if ($multi->performing
) { return;
} curl_multi_remove_handle($multi->handle,
$ch);
curl_setopt_array($ch,
[ \CURLOPT_NOPROGRESS => true,
\CURLOPT_PROGRESSFUNCTION => null,