tidal / WampWatch

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/Subscription/Collection.php

Spacing +3 added lines, -3 removed lines

@@ -101,7 +101,7 @@ 
      */
     protected function doSubscribe()
     {
-        \React\Promise\all($this->getSubscriptionPromises())->done(function () {
+        \React\Promise\all($this->getSubscriptionPromises())->done(function() {
             $this->isSubscribed = true;
             $this->isSubscribing = false;
             $this->subscriptionPromise->resolve($this->subscriptions);
@@ -117,7 +117,7 @@ 
 
         foreach (array_keys($this->subscriptions) as $topic) {
             $promises[] = $this->session->subscribe($topic, $this->subscriptionCallbacks[$topic])
-                ->then(function (SubscribedMessage $msg) use ($topic) {
+                ->then(function(SubscribedMessage $msg) use ($topic) {
                     $this->subscriptions[$topic] = $msg->getSubscriptionId();
                     $this->subscriptionPromise->notify($topic);
 
@@ -133,7 +133,7 @@ 
      */
     public function unsubscribe()
     {
-        $resolver = function (callable $resolve) {
+        $resolver = function(callable $resolve) {
             $resolve();
         };
         $promise = new  Promise($resolver);

src/Tidal/WampWatch/MonitorTrait.php

Spacing +4 added lines, -4 removed lines

@@ -79,7 +79,7 @@ 
             $this->callInitialProcedure(),
         ];
 
-        \React\Promise\all($promises)->done(function () {
+        \React\Promise\all($promises)->done(function() {
             $this->isRunning = true;
             $this->emit('start', [$this->getList()]);
         });
@@ -164,12 +164,12 @@ 
         if (!isset($this->initialCallProcedure) || !isset($this->initialCallCallback)) {
             $this->initialCallDone = true;
 
-            return new  Promise(function (callable $resolve) {
+            return new  Promise(function(callable $resolve) {
                 $resolve();
             });
         }
 
-        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);
@@ -182,7 +182,7 @@ 
 
     private function getErrorCallback()
     {
-        return function ($error) {
+        return function($error) {
             $this->emit('error', [$error]);
 
             return $error;

src/Tidal/WampWatch/SubscriptionMonitor.php

Spacing +5 added lines, -5 removed lines

@@ -61,7 +61,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;
@@ -76,7 +76,7 @@ 
             return $this->retrieveSubscriptionIds();
         }
 
-        return new Promise(function (callable $resolve) {
+        return new Promise(function(callable $resolve) {
             $resolve($this->subscriptionIds);
         });
     }
@@ -99,7 +99,7 @@ 
 
     private function getCreateHandler()
     {
-        return function ($res) {
+        return function($res) {
             $sessionId = $res[0];
             $subscriptionInfo = $res[1];
             $this->emit('create', [$sessionId, $subscriptionInfo]);
@@ -108,7 +108,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]);
@@ -136,7 +136,7 @@ 
 
     protected function getSubscriptionIdRetrievalCallback()
     {
-        return function (\Thruway\CallResult $res) {
+        return function(\Thruway\CallResult $res) {
             /** @var \Thruway\Message\ResultMessage $message */
             $message = $res->getResultMessage();
             $list = $message->getArguments()[0];