【Laravel】Guzzleで並列の非同期リクエストを送ってみた

use GuzzleHttp\Pool;
use GuzzleHttp\Client;

$client = new Client();

//$urlListにリクエストを送るurlを代入します。
$urlList = [];

$requests = function ($urlLsit) use ($client) {
    foreach ($urlLsit as $url) {
        yield function() use ($client, $url) {
            //$client->getAsync($url)でリクエストを生成
            return $client->requestAsync('GET', $url);
        };
    }
};

$contents = [];

$pool = new Pool($client, $requests($urlLsit), [
    //同時リクエスト数を決める
    'concurrency' => 10, 
    //成功時の処理
    'fulfilled' => function ($response, $index) use ($urlLsit, &$contents) {
        $contents[$urlLsit[$index]] = [
        'html'             => $response->getBody()->getContents(),
        'status_code'      => $response->getStatusCode(),
        'response_header'  => $response->getHeaders()
        ];
    },
    //失敗時の処理
    'rejected' => function ($reason, $index) use ($urlLsit, &$contents) {
        // this is delivered each failed request
        $contents[$urlLsit[$index]] = [
        'html'   => '',
        'reason' => $reason
        ];
    },
]);

$promise = $pool->promise();

//全ての並列処理が終わるまで待機
$promise->wait();