wordpress-seo / vendor_prefixed / guzzlehttp / promises / src / Each.php

Each.php in Yoast SEO – Advanced SEO with real-time guidance and built-in AI 27.6, at vendor_prefixed/guzzlehttp/promises/src/Each.php

57 lines 2.6 KB

Raw Download Zip

1	<?php
2
3	declare (strict_types=1);
4	namespace YoastSEO_Vendor\GuzzleHttp\Promise;
5
6	final class Each
7	{
8	/**
9	* Given an iterator that yields promises or values, returns a promise that
10	* is fulfilled with a null value when the iterator has been consumed or
11	* the aggregate promise has been fulfilled or rejected.
12	*
13	* $onFulfilled is a function that accepts the fulfilled value, iterator
14	* index, and the aggregate promise. The callback can invoke any necessary
15	* side effects and choose to resolve or reject the aggregate if needed.
16	*
17	* $onRejected is a function that accepts the rejection reason, iterator
18	* index, and the aggregate promise. The callback can invoke any necessary
19	* side effects and choose to resolve or reject the aggregate if needed.
20	*
21	* @param mixed $iterable Iterator or array to iterate over.
22	*/
23	public static function of($iterable, ?callable $onFulfilled = null, ?callable $onRejected = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface
24	{
25	return (new \YoastSEO_Vendor\GuzzleHttp\Promise\EachPromise($iterable, ['fulfilled' => $onFulfilled, 'rejected' => $onRejected]))->promise();
26	}
27	/**
28	* Like of, but only allows a certain number of outstanding promises at any
29	* given time.
30	*
31	* $concurrency may be an integer or a function that accepts the number of
32	* pending promises and returns a numeric concurrency limit value to allow
33	* for dynamic a concurrency size.
34	*
35	* @param mixed $iterable
36	* @param int\|callable $concurrency
37	*/
38	public static function ofLimit($iterable, $concurrency, ?callable $onFulfilled = null, ?callable $onRejected = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface
39	{
40	return (new \YoastSEO_Vendor\GuzzleHttp\Promise\EachPromise($iterable, ['fulfilled' => $onFulfilled, 'rejected' => $onRejected, 'concurrency' => $concurrency]))->promise();
41	}
42	/**
43	* Like limit, but ensures that no promise in the given $iterable argument
44	* is rejected. If any promise is rejected, then the aggregate promise is
45	* rejected with the encountered rejection.
46	*
47	* @param mixed $iterable
48	* @param int\|callable $concurrency
49	*/
50	public static function ofLimitAll($iterable, $concurrency, ?callable $onFulfilled = null) : \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface
51	{
52	return self::ofLimit($iterable, $concurrency, $onFulfilled, function ($reason, $idx, \YoastSEO_Vendor\GuzzleHttp\Promise\PromiseInterface $aggregate) : void {
53	$aggregate->reject($reason);
54	});
55	}
56	}
57