tidal / WampWatch

src/Tidal/WampWatch/SubscriptionMonitor.php

Spacing +5 added lines, -5 removed lines

@@ -63,7 +63,7 @@ 
     public function getSubscriptionInfo($topic)
     {
         return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, $topic)->then(
-            function ($res) {
+            function($res) {
                 $this->emit('info', [$res]);
 
                 return $res;
@@ -78,7 +78,7 @@ 
             return $this->retrieveSubscriptionIds();
         }
 
-        return new Promise(function (callable $resolve) {
+        return new Promise(function(callable $resolve) {
             $resolve($this->subscriptionIds);
         });
     }
@@ -101,7 +101,7 @@ 
 
     private function getCreateHandler()
     {
-        return function ($res) {
+        return function($res) {
             $sessionId = $res[0];
             $subscriptionInfo = $res[1];
             $this->emit('create', [$sessionId, $subscriptionInfo]);
@@ -110,7 +110,7 @@ 
 
     private function getSubscriptionHandler($event)
     {
-        return function ($res) use ($event) {
+        return function($res) use ($event) {
             $sessionId = $res[0];
             $subscriptionId = $res[1];
             $this->emit($event, [$sessionId, $subscriptionId]);
@@ -138,7 +138,7 @@ 
 
     protected function getSubscriptionIdRetrievalCallback()
     {
-        return function ($res) {
+        return function($res) {
             $this->setList($res);
             $this->emit('list', [
                 $this->subscriptionIds->exact,

src/Tidal/WampWatch/SessionMonitor.php

Spacing +6 added lines, -6 removed lines

@@ -67,12 +67,12 @@ 
     public function getSessionInfo($sessionId)
     {
         return $this->session->call(self::SESSION_INFO_TOPIC, [$sessionId])->then(
-            function ($res) {
+            function($res) {
                 $this->emit('info', [$res]);
 
                 return $res;
             },
-            function ($error) {
+            function($error) {
                 $this->emit('error', [$error]);
             }
         );
@@ -91,7 +91,7 @@ 
             return $this->retrieveSessionIds();
         }
 
-        return new Promise(function (callable $resolve) {
+        return new Promise(function(callable $resolve) {
             $resolve($this->sessionIds);
         });
     }
@@ -167,7 +167,7 @@ 
         // @var \Tidal\WampWatch\Subscription\Collection
         $collection = $this->getMetaSubscriptionCollection();
 
-        $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;
@@ -175,7 +175,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();
@@ -202,7 +202,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 +5 added lines, -5 removed lines

@@ -74,10 +74,10 @@ 
      */
     public function start()
     {
-        $this->getMetaSubscriptionCollection()->subscribe()->done(function () {
+        $this->getMetaSubscriptionCollection()->subscribe()->done(function() {
             $this->checkStarted();
         });
-        $this->callInitialProcedure()->done(function () {
+        $this->callInitialProcedure()->done(function() {
             $this->checkStarted();
         });
 
@@ -160,14 +160,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);
@@ -203,7 +203,7 @@ 
 
     private function getErrorCallback()
     {
-        return function ($error) {
+        return function($error) {
             $this->emit('error', [$error]);
 
             return $error;