HTTP Coroutines

amphp.php

<?php

function makeRequest(int $delay)
{
    $client = new Amp\Artax\DefaultClient;

    echo "Making request [delay = $delay]\n";
    $response = yield $client->request('https://mockbin.org/delay/' . $delay);

    echo "Response received [delay = $delay]\n";
    $body = yield $response->getBody();

    print_r(json_decode($body, true));
}

$requests = [
    Amp\call('makeRequest', 5000),
    Amp\call('makeRequest', 500)
];

echo "Start\n";
Amp\Promise\wait(Amp\Promise\all($requests));
echo "Waiting...\n";

guzzle.php

<?php

use Function GuzzleHttp\Promise\coroutine;

function call(callable $callback, ...$args)
{
    return coroutine(function() use ($callback, $args) {
        return $callback(...$args);
    });
}

function client()
{
    static $client;
    $client = $client ?? new GuzzleHttp\Client;
    return $client;
}

function makeRequest(int $delay)
{
    $client = new GuzzleHttp\Client;

    echo "Making request [delay = $delay]\n";
    // $response = yield $client->getAsync('https://mockbin.org/delay/' . $delay);
    $response = yield client()->getAsync('https://mockbin.org/delay/' . $delay);

    echo "Response received [delay = $delay]\n";
    $result = json_decode($response->getBody()->getContents(), true);
    print_r($result);
}

echo "Start\n";

$promises = [
    call('makeRequest', 5000),
    call('makeRequest', 500),
    call('makeRequest', 0)
];

\GuzzleHttp\Promise\unwrap($promises);

echo "Finished\n";