🚧 integrate EventLoop->promiseAll

BedrockStreaming · Apr 21, 2021 · b75a49c · b75a49c
1 parent 7bed8a1
commit b75a49c
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/Adapter/Swoole/EventLoop.php b/src/Adapter/Swoole/EventLoop.php
@@ -7,7 +7,6 @@
 use M6Web\Tornado\Deferred;
 use M6Web\Tornado\Promise;
 use Swoole\Coroutine;
-use Swoole\Coroutine\WaitGroup;
 use Swoole\Event;
 use RuntimeException;
 use function extension_loaded;
@@ -64,8 +63,17 @@ public function promiseAll(Promise ...$promises): Promise
     {
         $promise = new YieldPromise();
 
+        $ticks = count($promises);
+        $result = [];
+        $key = 0;
         foreach ($promises as $p) {
-
+            $result[$key] = $this->wait($p);
+            $ticks--;
+            if($ticks === 0) {
+                ksort($result);
+                $promise->resolve($result);
+            }
+            $key++;
         }
 
         return $promise;