tidal / WampWatch

src/Tidal/WampWatch/SessionMonitor.php

Spacing +8 added lines, -8 removed lines

@@ -103,13 +103,13 @@ 
     public function getSessionInfo($sessionId, callable $callback = null)
     {
         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
-            function ($res) use ($callback) {
+            function($res) use ($callback) {
                 $this->emit('info', [$res[0]]);
                 if ($callback !== null) {
                     $callback($res[0]);
                 }
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );
@@ -204,25 +204,25 @@ 
     protected function startSubscriptions()
     {
         // subscription to 'wamp.session.on_join'
-        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function (array $res) {
+        $this->session->subscribe(self::SESSION_JOIN_TOPIC, function(array $res) {
             $sessionInfo = $res[0];
             if (!$this->validateSessionInfo($sessionInfo) || $this->hasSession($sessionInfo)) {
                 return;
             }
             $this->addSession($sessionInfo);
-        })->then(function (SubscribedMessage $msg) {
+        })->then(function(SubscribedMessage $msg) {
             $this->joinSubscriptionId = $msg->getSubscriptionId();
             $this->checkStarted();
         });
 
         // subscription to 'wamp.session.on_leave'
-        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function (array $res) {
+        $this->session->subscribe(self::SESSION_LEAVE_TOPIC, function(array $res) {
             // @bug : wamp.session.on_leave is bugged as of crossbar.io 0.11.0
             // will provide sessionID when Browser closes/reloads,
             // but not when calling connection.close();
             $sessionId = (int) $res[0];
             $this->removeSessionId($sessionId);
-        })->then(function (SubscribedMessage $msg) {
+        })->then(function(SubscribedMessage $msg) {
             $this->leaveSubscriptionId = $msg->getSubscriptionId();
             $this->checkStarted();
         });
@@ -249,7 +249,7 @@ 
     protected function retrieveSessionIds(callable $callback = null)
     {
         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(
-            function ($res) use ($callback) {
+            function($res) use ($callback) {
                 // remove our own sessionID from the tracked sessions
                 $sessionIds = $this->removeOwnSessionId($res[0]);
                 $this->setList($sessionIds);
@@ -260,7 +260,7 @@ 
                 $this->calledList = true;
                 $this->checkStarted();
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );