wip

laravel · Nov 29, 2023 · 23eb0c8 · 23eb0c8
1 parent e538ceb
commit 23eb0c8
Showing 1 changed file with 7 additions and 10 deletions.
diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php
@@ -5,7 +5,6 @@
 use Laravel\Reverb\Contracts\ChannelConnectionManager;
 use Laravel\Reverb\Contracts\Connection;
 use React\Promise\Deferred;
-use Spatie\Fork\Fork;
 
 class Channel
 {
@@ -109,15 +108,13 @@ public function broadcastToAll(array $payload): void
         $chunks = array_chunk($this->connections(), 5000);
 
         array_map(function ($connections) use ($message) {
-            return function () use ($connections, $message) {
-                $promise = new Deferred;
-
-                $promise->resolve(function () use ($connections, $message) {
-                    foreach ($connections as $connection) {
-                        $connection->send($message);
-                    }
-                });   
-            };
+            $promise = new Deferred;
+
+            $promise->resolve(function () use ($connections, $message) {
+                foreach ($connections as $connection) {
+                    $connection->send($message);
+                }
+            });
         }, $chunks);
     }