Merge pull request #35 from reactphp-parallel/add-wyrihaximus-react-event-loop-rx-scheduler-hook-up-for-scheduler-hook-up

Add wyrihaximus/react-event-loop-rx-scheduler-hook-up for scheduler hook up

Author: WyriHaximus

composer.json

@@ -17,7 +17,8 @@
         "react/promise": "^2.11 || ^3.1",
         "reactivex/rxphp": "^2.0.12",
         "wyrihaximus/constants": "^1.6",
-        "wyrihaximus/react-awaitable-observable": "^1.1"
+        "wyrihaximus/react-awaitable-observable": "^1.1",
+        "wyrihaximus/react-event-loop-rx-scheduler-hook-up": "^0.1.1"
     },
     "require-dev": {
         "wyrihaximus/async-test-utilities": "^7.2",

composer.lock

@@ -48,7 +48,11 @@ public function channel(): void
 
         $promises = [];
         foreach ($channels as $channel) {
-            $promises[] = async(static fn (Channel $channel): array => [...$recvObservable->channel($channel)])($channel);
+            $promises[] = async(
+                static fn (Channel $channel): array => [
+                    ...$recvObservable->channel($channel),
+                ]
+            )($channel);
         }
 
         $rd = await(all($promises));