Browse code

added appinfo/info.xml appinfo/signature.json CHANGELOG.txt lib/AppInfo/Application.php css/style.css providers/Plivo

DoubleBastionAdmin authored on 05/11/2025 13:35:09
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/promises/src/Each.php
History View file @ 976eaee
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,81 @@
1 
+<?php
2 
+
3 
+declare(strict_types=1);
4 
+
5 
+namespace GuzzleHttp\Promise;
6 
+
7 
+final class Each
8 
+{
9 
+    /**
10 
+     * Given an iterator that yields promises or values, returns a promise that
11 
+     * is fulfilled with a null value when the iterator has been consumed or
12 
+     * the aggregate promise has been fulfilled or rejected.
13 
+     *
14 
+     * $onFulfilled is a function that accepts the fulfilled value, iterator
15 
+     * index, and the aggregate promise. The callback can invoke any necessary
16 
+     * side effects and choose to resolve or reject the aggregate if needed.
17 
+     *
18 
+     * $onRejected is a function that accepts the rejection reason, iterator
19 
+     * index, and the aggregate promise. The callback can invoke any necessary
20 
+     * side effects and choose to resolve or reject the aggregate if needed.
21 
+     *
22 
+     * @param mixed $iterable Iterator or array to iterate over.
23 
+     */
24 
+    public static function of(
25 
+        $iterable,
26 
+        ?callable $onFulfilled = null,
27 
+        ?callable $onRejected = null
28 
+    ): PromiseInterface {
29 
+        return (new EachPromise($iterable, [
30 
+            'fulfilled' => $onFulfilled,
31 
+            'rejected' => $onRejected,
32 
+        ]))->promise();
33 
+    }
34 
+
35 
+    /**
36 
+     * Like of, but only allows a certain number of outstanding promises at any
37 
+     * given time.
38 
+     *
39 
+     * $concurrency may be an integer or a function that accepts the number of
40 
+     * pending promises and returns a numeric concurrency limit value to allow
41 
+     * for dynamic a concurrency size.
42 
+     *
43 
+     * @param mixed        $iterable
44 
+     * @param int|callable $concurrency
45 
+     */
46 
+    public static function ofLimit(
47 
+        $iterable,
48 
+        $concurrency,
49 
+        ?callable $onFulfilled = null,
50 
+        ?callable $onRejected = null
51 
+    ): PromiseInterface {
52 
+        return (new EachPromise($iterable, [
53 
+            'fulfilled' => $onFulfilled,
54 
+            'rejected' => $onRejected,
55 
+            'concurrency' => $concurrency,
56 
+        ]))->promise();
57 
+    }
58 
+
59 
+    /**
60 
+     * Like limit, but ensures that no promise in the given $iterable argument
61 
+     * is rejected. If any promise is rejected, then the aggregate promise is
62 
+     * rejected with the encountered rejection.
63 
+     *
64 
+     * @param mixed        $iterable
65 
+     * @param int|callable $concurrency
66 
+     */
67 
+    public static function ofLimitAll(
68 
+        $iterable,
69 
+        $concurrency,
70 
+        ?callable $onFulfilled = null
71 
+    ): PromiseInterface {
72 
+        return self::ofLimit(
73 
+            $iterable,
74 
+            $concurrency,
75 
+            $onFulfilled,
76 
+            function ($reason, $idx, PromiseInterface $aggregate): void {
77 
+                $aggregate->reject($reason);
78 
+            }
79 
+        );
80 
+    }
81 
+}
Browse code

removed appinfo/info.xml appinfo/signature.json CHANGELOG.txt lib/AppInfo/Application.php css/style.css providers/Plivo

DoubleBastionAdmin authored on 05/11/2025 13:12:22
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/promises/src/Each.php
History View file @ b79bd44
1 1 
deleted file mode 100644
... ... 
@@ -1,90 +0,0 @@
1 
-<?php
2 
-
3 
-namespace GuzzleHttp\Promise;
4 
-
5 
-final class Each
6 
-{
7 
-    /**
8 
-     * Given an iterator that yields promises or values, returns a promise that
9 
-     * is fulfilled with a null value when the iterator has been consumed or
10 
-     * the aggregate promise has been fulfilled or rejected.
11 
-     *
12 
-     * $onFulfilled is a function that accepts the fulfilled value, iterator
13 
-     * index, and the aggregate promise. The callback can invoke any necessary
14 
-     * side effects and choose to resolve or reject the aggregate if needed.
15 
-     *
16 
-     * $onRejected is a function that accepts the rejection reason, iterator
17 
-     * index, and the aggregate promise. The callback can invoke any necessary
18 
-     * side effects and choose to resolve or reject the aggregate if needed.
19 
-     *
20 
-     * @param mixed    $iterable    Iterator or array to iterate over.
21 
-     * @param callable $onFulfilled
22 
-     * @param callable $onRejected
23 
-     *
24 
-     * @return PromiseInterface
25 
-     */
26 
-    public static function of(
27 
-        $iterable,
28 
-        callable $onFulfilled = null,
29 
-        callable $onRejected = null
30 
-    ) {
31 
-        return (new EachPromise($iterable, [
32 
-            'fulfilled' => $onFulfilled,
33 
-            'rejected'  => $onRejected
34 
-        ]))->promise();
35 
-    }
36 
-
37 
-    /**
38 
-     * Like of, but only allows a certain number of outstanding promises at any
39 
-     * given time.
40 
-     *
41 
-     * $concurrency may be an integer or a function that accepts the number of
42 
-     * pending promises and returns a numeric concurrency limit value to allow
43 
-     * for dynamic a concurrency size.
44 
-     *
45 
-     * @param mixed        $iterable
46 
-     * @param int|callable $concurrency
47 
-     * @param callable     $onFulfilled
48 
-     * @param callable     $onRejected
49 
-     *
50 
-     * @return PromiseInterface
51 
-     */
52 
-    public static function ofLimit(
53 
-        $iterable,
54 
-        $concurrency,
55 
-        callable $onFulfilled = null,
56 
-        callable $onRejected = null
57 
-    ) {
58 
-        return (new EachPromise($iterable, [
59 
-            'fulfilled'   => $onFulfilled,
60 
-            'rejected'    => $onRejected,
61 
-            'concurrency' => $concurrency
62 
-        ]))->promise();
63 
-    }
64 
-
65 
-    /**
66 
-     * Like limit, but ensures that no promise in the given $iterable argument
67 
-     * is rejected. If any promise is rejected, then the aggregate promise is
68 
-     * rejected with the encountered rejection.
69 
-     *
70 
-     * @param mixed        $iterable
71 
-     * @param int|callable $concurrency
72 
-     * @param callable     $onFulfilled
73 
-     *
74 
-     * @return PromiseInterface
75 
-     */
76 
-    public static function ofLimitAll(
77 
-        $iterable,
78 
-        $concurrency,
79 
-        callable $onFulfilled = null
80 
-    ) {
81 
-        return each_limit(
82 
-            $iterable,
83 
-            $concurrency,
84 
-            $onFulfilled,
85 
-            function ($reason, $idx, PromiseInterface $aggregate) {
86 
-                $aggregate->reject($reason);
87 
-            }
88 
-        );
89 
-    }
90 
-}
Browse code

Added README.md appinfo/info.xml appinfo/signature.json lib/Controller/AuthorApiController.php and the providers directory

DoubleBastionAdmin authored on 20/08/2022 16:33:00
Showing 1 changed files
providers/Plivo/vendor/guzzlehttp/promises/src/Each.php
History View file @ f3755e3
1 1 
new file mode 100644
... ... 
@@ -0,0 +1,90 @@
1 
+<?php
2 
+
3 
+namespace GuzzleHttp\Promise;
4 
+
5 
+final class Each
6 
+{
7 
+    /**
8 
+     * Given an iterator that yields promises or values, returns a promise that
9 
+     * is fulfilled with a null value when the iterator has been consumed or
10 
+     * the aggregate promise has been fulfilled or rejected.
11 
+     *
12 
+     * $onFulfilled is a function that accepts the fulfilled value, iterator
13 
+     * index, and the aggregate promise. The callback can invoke any necessary
14 
+     * side effects and choose to resolve or reject the aggregate if needed.
15 
+     *
16 
+     * $onRejected is a function that accepts the rejection reason, iterator
17 
+     * index, and the aggregate promise. The callback can invoke any necessary
18 
+     * side effects and choose to resolve or reject the aggregate if needed.
19 
+     *
20 
+     * @param mixed    $iterable    Iterator or array to iterate over.
21 
+     * @param callable $onFulfilled
22 
+     * @param callable $onRejected
23 
+     *
24 
+     * @return PromiseInterface
25 
+     */
26 
+    public static function of(
27 
+        $iterable,
28 
+        callable $onFulfilled = null,
29 
+        callable $onRejected = null
30 
+    ) {
31 
+        return (new EachPromise($iterable, [
32 
+            'fulfilled' => $onFulfilled,
33 
+            'rejected'  => $onRejected
34 
+        ]))->promise();
35 
+    }
36 
+
37 
+    /**
38 
+     * Like of, but only allows a certain number of outstanding promises at any
39 
+     * given time.
40 
+     *
41 
+     * $concurrency may be an integer or a function that accepts the number of
42 
+     * pending promises and returns a numeric concurrency limit value to allow
43 
+     * for dynamic a concurrency size.
44 
+     *
45 
+     * @param mixed        $iterable
46 
+     * @param int|callable $concurrency
47 
+     * @param callable     $onFulfilled
48 
+     * @param callable     $onRejected
49 
+     *
50 
+     * @return PromiseInterface
51 
+     */
52 
+    public static function ofLimit(
53 
+        $iterable,
54 
+        $concurrency,
55 
+        callable $onFulfilled = null,
56 
+        callable $onRejected = null
57 
+    ) {
58 
+        return (new EachPromise($iterable, [
59 
+            'fulfilled'   => $onFulfilled,
60 
+            'rejected'    => $onRejected,
61 
+            'concurrency' => $concurrency
62 
+        ]))->promise();
63 
+    }
64 
+
65 
+    /**
66 
+     * Like limit, but ensures that no promise in the given $iterable argument
67 
+     * is rejected. If any promise is rejected, then the aggregate promise is
68 
+     * rejected with the encountered rejection.
69 
+     *
70 
+     * @param mixed        $iterable
71 
+     * @param int|callable $concurrency
72 
+     * @param callable     $onFulfilled
73 
+     *
74 
+     * @return PromiseInterface
75 
+     */
76 
+    public static function ofLimitAll(
77 
+        $iterable,
78 
+        $concurrency,
79 
+        callable $onFulfilled = null
80 
+    ) {
81 
+        return each_limit(
82 
+            $iterable,
83 
+            $concurrency,
84 
+            $onFulfilled,
85 
+            function ($reason, $idx, PromiseInterface $aggregate) {
86 
+                $aggregate->reject($reason);
87 
+            }
88 
+        );
89 
+    }
90 
+}