1 回答
TA贡献1936条经验 获得超7个赞
我以这种方式解决这个问题:
$requests = function ($total) {
$uri = 'http://127.0.0.1:8126/guzzle-server/perf';
for ($i = 0; $i < $total; $i++) {
$myAdditionalId = $i;
$promise = $client->getAsync($uri);
$promise->then(function () use ($myAdditionalId){
//add callback with function on success
echo $myAdditionalId;
});
yield function()use($promise){return $promise;};
}
};
$pool = new Pool($client, $requests(100), [
'concurrency' => 5,
'rejected' => function (RequestException $reason, $index) {
// this is delivered each failed request
},
]);
- 1 回答
- 0 关注
- 148 浏览
添加回答
举报
