diff --git a/src/WebSockets/Channels/ChannelManager.php b/src/WebSockets/Channels/ChannelManager.php index 765bc23..b8cd4f4 100644 --- a/src/WebSockets/Channels/ChannelManager.php +++ b/src/WebSockets/Channels/ChannelManager.php @@ -47,6 +47,10 @@ class ChannelManager public function removeFromAllChannels(ConnectionInterface $connection) { + if (! isset($connection->client)) { + return; + } + collect($this->channels[$connection->client->appId])->each->unsubscribe($connection); collect($this->channels[$connection->client->appId])