Guzzle concurrent promise requests

guzzle-concurrent-promise.php

<?php

use GuzzleHttp\Promise as P;

require_once __DIR__.'/vendor/autoload.php';

function createChain($client, $i) {
    $delay = rand(0, 5);
    echo "delay-$i-$delay\n";
    $first = $client->getAsync("http://httpbin.org/delay/$delay")->then(function($resp) use($i) {
        echo "$i-1\n";
        return json_decode($resp->getBody())->origin;
    });

    $second = $first->then(function($ip) use ($client) {
        return $client->getAsync("http://httpbin.org/get?ip=$ip&second");
    })->then(function($resp) use ($i) {
        echo "$i-2\n";
        return json_decode($resp->getBody())->args;
    });

    $third = P\all([$first, $second])->then(function($args) use ($client) {
        list($ip, $get2) = $args;
        return $client->getAsync("http://httpbin.org/get?ip=$ip&third");
    })->then(function($resp) use ($i) {
        echo "$i-3\n";
        return json_decode($resp->getBody())->args;
    });

    return P\all([$first, $second, $third]);
}

$chains = [];
$client = new GuzzleHttp\Client();
for ($i = 0; $i < 10; $i++) {
    $chains[] = createChain($client, $i);
}
$r = P\all($chains)->wait();
var_dump($r);

echo "end\n";