tidal / WampWatch

src/Tidal/WampWatch/SessionMonitor.php

Spacing +6 added lines, -6 removed lines

@@ -67,13 +67,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]);
             }
         );
@@ -170,7 +170,7 @@ 
         // @var \Tidal\WampWatch\Subscription\Collection
         $collection = $this->getSubscriptionCollection();
 
-        $collection->addSubscription(self::SESSION_JOIN_TOPIC, function (array $res) {
+        $collection->addSubscription(self::SESSION_JOIN_TOPIC, function(array $res) {
             $sessionInfo = $res[0];
             if (!$this->validateSessionInfo($sessionInfo) || $this->hasSession($sessionInfo)) {
                 return;
@@ -178,7 +178,7 @@ 
             $this->addSession($sessionInfo);
         });
 
-        $collection->addSubscription(self::SESSION_LEAVE_TOPIC, function (array $res) {
+        $collection->addSubscription(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();
@@ -199,7 +199,7 @@ 
         $this->session->call(self::SESSION_LIST_TOPIC, [])
             ->then(
                 $this->getSessionIdRetrievalCallback()
-            )->done(function ($res) use ($callback) {
+            )->done(function($res) use ($callback) {
                 if ($callback !== null) {
                     $callback($res);
                 }
@@ -208,7 +208,7 @@ 
 
     protected function getSessionIdRetrievalCallback()
     {
-        return function ($res) {
+        return function($res) {
             // remove our own sessionID from the tracked sessions
             $sessionIds = $this->removeOwnSessionId($res[0]);
             $this->setList($sessionIds);

src/Tidal/WampWatch/MonitorTrait.php

Spacing +4 added lines, -4 removed lines

@@ -74,10 +74,10 @@ 
      */
     public function start()
     {
-        $this->getSubscriptionCollection()->subscribe()->done(function () {
+        $this->getSubscriptionCollection()->subscribe()->done(function() {
             $this->checkStarted();
         });
-        $this->callInitialProcedure()->done(function () {
+        $this->callInitialProcedure()->done(function() {
             $this->checkStarted();
         });
 
@@ -152,14 +152,14 @@ 
     {
         if (!isset($this->initialCallProcedure) || !isset($this->initialCallCallback)) {
             $this->initialCallDone = true;
-            $resolver = function (callable $resolve) {
+            $resolver = function(callable $resolve) {
                 $resolve();
             };
 
             return new  Promise($resolver);
         }
 
-        return $this->session->call($this->initialCallProcedure, [])->then(function ($res) {
+        return $this->session->call($this->initialCallProcedure, [])->then(function($res) {
             $this->initialCallDone = true;
             $cb = $this->initialCallCallback;
             $cb($res);