Recent Posts标签Sep 29, 2018 – GuzzleHttp

use GuzzleHttpPromisePromise;

$promise = new Promise();
$promise->then(
    // $onFulfilled
    function ($value) {
        echo 'The promise was fulfilled.';
    },
    // $onRejected
    function ($reason) {
        echo 'The promise was rejected.';
    }
);

use GuzzleHttpPromisePromise;

$promise = new Promise();
$promise
    ->then(function ($value) {
        // Return a value and don't break the chain
        return "Hello, " . $value; //创建一个新的promise实例，并且为之注册下一个then中的成功和失败的回调函数
    })
    // This then is executed after the first then and receives the value
    // returned from the first then.
    ->then(function ($value) {
        echo $value;
    });

// Resolving the promise triggers the $onFulfilled callbacks and outputs
// "Hello, reader".
$promise->resolve('reader.');

$promise = new Promise();
$nextPromise = new Promise();

$promise
    ->then(function ($value) use ($nextPromise) {
        echo $value;
        return $nextPromise;
    })
    ->then(function ($value) {
        echo $value;
    });

// Triggers the first callback and outputs "A"
$promise->resolve('A');
// Triggers the second callback and outputs "B"
$nextPromise->resolve('B');

class Promise {
	public function __construct(
        callable $waitFn = null,
        callable $cancelFn = null
    ) {
        $this->waitFn = $waitFn;
        $this->cancelFn = $cancelFn;
    }
}

$promise = new Promise(function () use (&$promise) {
    $promise->resolve('foo');
});

// Calling wait will return the value of the promise.
echo $promise->wait(); // outputs "foo"

$promise = new Promise(function () use (&$promise) {
    throw new Exception('foo');
});

$promise->wait(); // throws the exception.

$promise = new Promise(function () { die('this is not called!'); });
$promise->resolve('foo');
echo $promise->wait(); // outputs "foo"

$promise = new Promise();
$promise->reject('foo');
$promise->wait();//throws the exception.

use GuzzleHttpClient;
use GuzzleHttpPool;
use GuzzleHttpPromisePromise;
$client = new Client();


$request = function ($total) {
    $uri = 'https://shanghai.anjuke.com/community/view/';
    for ($i=0; $i<$total; $i++) {
        yield new GuzzleHttpPsr7Request('Get', $uri . $i);
    }
};

$pool = new Pool($client, $request(10), [
        'concurrency' => 5,
        'fulfilled' => function ($response, $index) {
            echo 'fulfilled ' . $index . "n";
        },
        'rejected' => function ($reason, $index) {
            echo 'rejected ' . $index . "n";
        },
    ]
);

$promise = $pool->promise();

$promise->wait();