Problema

Estamos tentando fazer solicitações assíncronas simultâneas usando guzzle. Depois de passar por alguns recursos, comoesta eesta, criamos um código que é compartilhado abaixo. No entanto, não está funcionando conforme o esperado.

Parece que o Guzzle está fazendo essas solicitações de forma síncrona, em vez de assíncrona.

Expectativa

Apenas para fins de teste, estamos atingindo um URL interno, que dorme por 5 segundos. Com uma simultaneidade de 10, esperamos que todas as 10 solicitações sejam inicialmente enfileiradas e enviadas ao servidorquase simultaneamente, onde esperam 5 segundos e, em seguida,quase tudo isso terminará quase ao mesmo tempo. O que faria o cliente guzzle receber 10 novas solicitações do iterador e assim por diante.

Código

    $iterator = function() {
        $index = 0;
        while (true) {
            $client = new Client(['timeout'=>20]);
            $url = 'http://localhost/wait/5' . $index++;
            $request = new Request('GET',$url, []);
            echo "Queuing $url @ " . (new Carbon())->format('Y-m-d H:i:s') . PHP_EOL;
            yield $client
                ->sendAsync($request)
                ->then(function(Response $response) use ($request) {
                    return [$request, $response];
                });
        }
    };

    $promise = \GuzzleHttp\Promise\each_limit(
        $iterator(),
        10,  /// concurrency,
        function($result, $index) {
            /** GuzzleHttp\Psr7\Request $request */
            list($request, $response) = $result;
            echo (string) $request->getUri() . ' completed '.PHP_EOL;
        },
        function(RequestException $reason, $index) {
            // left empty for brevity
        }
    );
    $promise->wait();

Resultados reais

Concluímos que o Guzzle nunca fez uma segunda solicitação até a primeira terminar. e assim por diante.

Queuing http://localhost/wait/5/1 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/2 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/3 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/4 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/5 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/6 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/7 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/8 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/9 @ 2017-09-01 17:15:28
Queuing http://localhost/wait/5/10 @ 2017-09-01 17:15:28
http://localhost/wait/5/1 completed
Queuing http://localhost/wait/5/11 @ 2017-09-01 17:15:34
http://localhost/wait/5/2 completed
Queuing http://localhost/wait/5/12 @ 2017-09-01 17:15:39
http://localhost/wait/5/3 completed
Queuing http://localhost/wait/5/13 @ 2017-09-01 17:15:45
http://localhost/wait/5/4 completed
Queuing http://localhost/wait/5/14 @ 2017-09-01 17:15:50 

Informações do SO / versão

UbuntuPHP / 7.1.3GuzzleHttp / 6.2.1enrolar / 7.47.0

O problema pode estar em \ GuzzleHttp \ Promise \ each_limit .. que talvez não inicie ou resolva a promessa com rapidez suficiente. Pode ser possível que tenhamos que enganar issotickexternamente.