02-await-any.php

<?php

use Clue\React\Block;

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

/**
 * @param string $url1
 * @param string $url2
 * @return Psr\Http\Message\ResponseInterface
 * @throws Exception when HTTP request fails
 */
function requestHttpFastestOfMultiple($url1, $url2)
{
    // use a unique event loop instance for all parallel operations
    $loop = React\EventLoop\Factory::create();

    // This example uses an HTTP client
    $browser = new React\Http\Browser($loop);

    // set up two parallel requests
    $promises = array(
        $browser->get($url1),
        $browser->get($url2)
    );

    try {
        // keep the loop running (i.e. block) until the first response arrives
        $fasterResponse = Block\awaitAny($promises, $loop);

        // promise successfully fulfilled with $fasterResponse
        return $fasterResponse;
    } catch (Exception $exception) {
        // promise rejected with $exception
        throw $exception;
    }
}

$first = requestHttpFastestOfMultiple('http://www.google.com/', 'http://www.google.co.uk/');
echo $first->getBody();