use promises

laravel · Nov 30, 2023 · dd70f4e · dd70f4e
1 parent 67639ed
commit dd70f4e
Showing 1 changed file with 3 additions and 20 deletions.
diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php
@@ -4,8 +4,7 @@
 
 use Laravel\Reverb\Contracts\ChannelConnectionManager;
 use Laravel\Reverb\Contracts\Connection;
-use React\EventLoop\Loop;
-use Spatie\Fork\Fork;
+use React\Promise\Promise;
 
 class Channel
 {
@@ -106,31 +105,15 @@ public function broadcastToAll(array $payload): void
     {
         $message = json_encode($payload);
 
-        $chunks = array_chunk($this->connections(), 5000);
-
-        $loop = Loop::get();
+        $chunks = array_chunk($this->connections(), 1000);
 
         foreach ($chunks as $connections) {
-            $loop->futureTick(function () use ($connections, $message) {
+            new Promise(function ($resolve) use ($connections, $message) {
                 foreach ($connections as $connection) {
-                    dump('Sending');
                     $connection->send($message);
                 }
             });
         }
-
-        // $forks = array_map(function ($connections) use ($message) {
-        //     return function () use ($connections, $message) {
-        //         foreach ($connections as $connection) {
-        //             dump('Sending');
-        //             $connection->send($message);
-        //         }
-        //     };
-        // }, $chunks);
-
-        // dump($forks);
-
-        // (new Fork)->run(...$forks);
     }
 
     /**