<?php

[0] Fix | Delete

[1] Fix | Delete

declare (strict_types=1);

[2] Fix | Delete

namespace YoastSEO_Vendor\GuzzleHttp\Promise;

[3] Fix | Delete

[4] Fix | Delete

final class Each

[5] Fix | Delete

{

[6] Fix | Delete

/**

[7] Fix | Delete

* Given an iterator that yields promises or values, returns a promise that

[8] Fix | Delete

* is fulfilled with a null value when the iterator has been consumed or

[9] Fix | Delete

* the aggregate promise has been fulfilled or rejected.

[10] Fix | Delete

*

[11] Fix | Delete

* $onFulfilled is a function that accepts the fulfilled value, iterator

[12] Fix | Delete

* index, and the aggregate promise. The callback can invoke any necessary

[13] Fix | Delete

* side effects and choose to resolve or reject the aggregate if needed.

[14] Fix | Delete

*

[15] Fix | Delete

* $onRejected is a function that accepts the rejection reason, iterator

[16] Fix | Delete

* index, and the aggregate promise. The callback can invoke any necessary

[17] Fix | Delete

* side effects and choose to resolve or reject the aggregate if needed.

[18] Fix | Delete

*

[19] Fix | Delete

* @param mixed $iterable Iterator or array to iterate over.

[20] Fix | Delete

*/

[21] Fix | Delete

public static function of($iterable, callable $onFulfilled = null, callable $onRejected = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface

[22] Fix | Delete

{

[23] Fix | Delete

return (new \YoastSEO_Vendor\GuzzleHttp\Promise\EachPromise($iterable, ['fulfilled' => $onFulfilled, 'rejected' => $onRejected]))->promise();

[24] Fix | Delete

}

[25] Fix | Delete

/**

[26] Fix | Delete

* Like of, but only allows a certain number of outstanding promises at any

[27] Fix | Delete

* given time.

[28] Fix | Delete

*

[29] Fix | Delete

* $concurrency may be an integer or a function that accepts the number of

[30] Fix | Delete

* pending promises and returns a numeric concurrency limit value to allow

[31] Fix | Delete

* for dynamic a concurrency size.

[32] Fix | Delete

*

[33] Fix | Delete

* @param mixed $iterable

[34] Fix | Delete

* @param int|callable $concurrency

[35] Fix | Delete

*/

[36] Fix | Delete

public static function ofLimit($iterable, $concurrency, callable $onFulfilled = null, callable $onRejected = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface

[37] Fix | Delete

{

[38] Fix | Delete

return (new \YoastSEO_Vendor\GuzzleHttp\Promise\EachPromise($iterable, ['fulfilled' => $onFulfilled, 'rejected' => $onRejected, 'concurrency' => $concurrency]))->promise();

[39] Fix | Delete

}

[40] Fix | Delete

/**

[41] Fix | Delete

* Like limit, but ensures that no promise in the given $iterable argument

[42] Fix | Delete

* is rejected. If any promise is rejected, then the aggregate promise is

[43] Fix | Delete

* rejected with the encountered rejection.

[44] Fix | Delete

*

[45] Fix | Delete

* @param mixed $iterable

[46] Fix | Delete

* @param int|callable $concurrency

[47] Fix | Delete

*/

[48] Fix | Delete

public static function ofLimitAll($iterable, $concurrency, callable $onFulfilled = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface

[49] Fix | Delete

{

[50] Fix | Delete

return self::ofLimit($iterable, $concurrency, $onFulfilled, function ($reason, $idx, \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface $aggregate) : void {

[51] Fix | Delete

$aggregate->reject($reason);

[52] Fix | Delete

});

[53] Fix | Delete

}

[54] Fix | Delete

}

[55] Fix | Delete

[56] Fix | Delete