blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip

This commit is contained in:
Marcel Pociot 2018-11-29 16:41:27 +01:00
parent 606f09f444
commit bdef2c29a9
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/WebSockets/Channels/Channel.php
View File

@ -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)