This commit is contained in:
freek 2018-12-01 12:27:36 +01:00
parent 84dad775e5
commit acaa7aa205
1 changed files with 9 additions and 9 deletions

View File

@ -12,17 +12,17 @@ class ChannelManager
/** @var array */ /** @var array */
protected $channels = []; protected $channels = [];
public function findOrCreate(string $appId, string $channelName): Channel public function findOrCreate(string $appId, string $channelName): Channel
{ {
if (!isset($this->channels[$appId][$channelName])) { if (!isset($this->channels[$appId][$channelName])) {
$channelClass = $this->determineChannelClass($channelName); $channelClass = $this->determineChannelClass($channelName);
$this->channels[$appId][$channelName] = new $channelClass($channelName); $this->channels[$appId][$channelName] = new $channelClass($channelName);
}
return $this->channels[$appId][$channelName];
} }
return $this->channels[$appId][$channelName];
}
public function find(string $appId, string $channelName): ?Channel public function find(string $appId, string $channelName): ?Channel
{ {
return $this->channels[$appId][$channelName] ?? null; return $this->channels[$appId][$channelName] ?? null;
@ -48,7 +48,7 @@ public function findOrCreate(string $appId, string $channelName): Channel
public function removeFromAllChannels(ConnectionInterface $connection) public function removeFromAllChannels(ConnectionInterface $connection)
{ {
if (! isset($connection->client)) { if (!isset($connection->client)) {
return; return;
} }