diff --git a/src/WebSockets/Channels/ChannelManager.php b/src/WebSockets/Channels/ChannelManager.php
index 2353455..fa77442 100644
--- a/src/WebSockets/Channels/ChannelManager.php
+++ b/src/WebSockets/Channels/ChannelManager.php
@@ -12,17 +12,17 @@ class ChannelManager
     /** @var array */
     protected $channels = [];
 
-public function findOrCreate(string $appId, string $channelName): Channel
-{
-    if (!isset($this->channels[$appId][$channelName])) {
-        $channelClass = $this->determineChannelClass($channelName);
+    public function findOrCreate(string $appId, string $channelName): Channel
+    {
+        if (!isset($this->channels[$appId][$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
     {
         return $this->channels[$appId][$channelName] ?? null;