From bdef2c29a95417ac551ea1478f5656311b884939 Mon Sep 17 00:00:00 2001
From: Marcel Pociot <m.pociot@gmail.com>
Date: Thu, 29 Nov 2018 16:41:27 +0100
Subject: [PATCH] wip

---
 src/WebSockets/Channels/Channel.php | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/src/WebSockets/Channels/Channel.php b/src/WebSockets/Channels/Channel.php
index 8933fc0..26038dd 100644
--- a/src/WebSockets/Channels/Channel.php
+++ b/src/WebSockets/Channels/Channel.php
@@ -91,9 +91,15 @@ class Channel
 
     public function broadcastToEveryoneExcept($payload, ?string $socketId = null)
     {
-        Collection::make($this->subscriptions)->reject(function ($existingConnection) use ($socketId) {
-            return $existingConnection->socketId === $socketId;
-        })->each->send(json_encode($payload));
+        if (is_null($socketId)) {
+            return $this->broadcast($payload);
+        }
+
+        foreach ($this->subscriptions as $connection) {
+            if ($connection->socketId !== $socketId) {
+                $connection->send(json_encode($payload));
+            }
+        }
     }
 
     public function broadcastToOthers(ConnectionInterface $connection, $payload)