tidal / WampWatch

src/Tidal/WampWatch/MonitorTrait.php

Doc Comments +11 added lines, -1 removed lines

@@ -152,6 +152,9 @@ 
             : $this->metaSubscriptionCollection = new SubscriptionCollection($this->session);
     }
 
+    /**
+     * @param string $procedure
+     */
     protected function setInitialCall($procedure, callable $callback)
     {
         $this->initialCallProcedure = (string) $procedure;
@@ -191,6 +194,9 @@ 
         };
     }
 
+    /**
+     * @param string $procedure
+     */
     private function retrieveCallData($procedure, callable $filter = null, $arguments = [])
     {
         $deferred = $this->createDeferred();
@@ -201,6 +207,10 @@ 
 
         $this->session->call($procedure, $arguments)
             ->then(
+
+                /**
+                 * @param string $res
+                 */
                 function ($res) use ($deferred, $filter) {
                     $deferred->resolve($filter($res));
                 },
@@ -211,7 +221,7 @@ 
     }
 
     /**
-     * @param $event
+     * @param string $event
      *
      * @return \Closure
      */

Spacing +8 added lines, -8 removed lines

@@ -81,7 +81,7 @@ 
             $this->callInitialProcedure(),
         ];
 
-        \React\Promise\all($promises)->done(function () {
+        \React\Promise\all($promises)->done(function() {
             $this->isRunning = true;
             $this->emit('start', [$this->getList()]);
         });
@@ -166,12 +166,12 @@ 
         if (!isset($this->initialCallProcedure) || !isset($this->initialCallCallback)) {
             $this->initialCallDone = true;
 
-            return $this->createPromise(function (callable $resolve) {
+            return $this->createPromise(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);
@@ -184,7 +184,7 @@ 
 
     private function getErrorCallback()
     {
-        return function ($error) {
+        return function($error) {
             $this->emit('error', [$error]);
 
             return $error;
@@ -195,13 +195,13 @@ 
     {
         $deferred = $this->createDeferred();
 
-        $filter = $filter ?: function ($res) {
+        $filter = $filter ?: function($res) {
             return $res;
         };
 
         $this->session->call($procedure, $arguments)
             ->then(
-                function ($res) use ($deferred, $filter) {
+                function($res) use ($deferred, $filter) {
                     $deferred->resolve($filter($res));
                 },
                 $this->getErrorCallback()
@@ -217,14 +217,14 @@ 
      */
     private function getSubscriptionHandler($event)
     {
-        return function ($res) use ($event) {
+        return function($res) use ($event) {
             $this->emit($event, $res);
         };
     }
 
     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];

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 (ErrorMessage $error) use ($sessionId) {
+            function(ErrorMessage $error) use ($sessionId) {
                 $this->emit('error', [$error, $sessionId]);
             }
         );
@@ -92,7 +92,7 @@ 
         }
 
         return $this->createPromise(
-            function (callable $resolve) {
+            function(callable $resolve) {
                 $resolve($this->getList());
             }
         );
@@ -169,7 +169,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;
@@ -177,7 +177,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();
@@ -207,7 +207,7 @@ 
      */
     protected function getSessionIdRetrievalCallback()
     {
-        return function ($res) {
+        return function($res) {
             $this->setList($res[0]);
             $sessionIds = $this->getList();
             $this->emit('list', [$sessionIds]);

src/Tidal/WampWatch/SubscriptionMonitor.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,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;
@@ -73,7 +73,7 @@ 
             return $this->retrieveSubscriptionIds();
         }
 
-        return $this->createPromise(function (callable $resolve) {
+        return $this->createPromise(function(callable $resolve) {
             $resolve($this->subscriptionIds);
         });
     }

src/Tidal/WampWatch/Subscription/Collection.php

Spacing +3 added lines, -3 removed lines

@@ -103,7 +103,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);
@@ -119,7 +119,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);
 
@@ -135,7 +135,7 @@ 
      */
     public function unsubscribe()
     {
-        $resolver = function (callable $resolve) {
+        $resolver = function(callable $resolve) {
             $resolve();
         };
         $promise = $this->createPromise($resolver);

src/Tidal/WampWatch/Stub/ClientSessionStub.php

Spacing +1 added lines, -1 removed lines

@@ -431,7 +431,7 @@
      */
     private function createDeferredAdapter(callable $canceller = null)
     {
-        $canceller = $canceller ?: function () {
+        $canceller = $canceller ?: function() {
         };
 
         return $this->getDeferredFactory()->create($canceller);