tidal / WampWatch

src/Tidal/WampWatch/MonitorTrait.php

Doc Comments +11 added lines, -1 removed lines

@@ -153,6 +153,9 @@ 
             : $this->metaSubscriptionCollection = new SubscriptionCollection($this->session);
     }
 
+    /**
+     * @param string $procedure
+     */
     protected function setInitialCall($procedure, callable $callback)
     {
         $this->initialCallProcedure = (string) $procedure;
@@ -192,6 +195,9 @@ 
         };
     }
 
+    /**
+     * @param string $procedure
+     */
     private function retrieveCallData($procedure, callable $filter = null, $arguments = [])
     {
         $deferred = new DeferredAdapter(
@@ -204,6 +210,10 @@ 
 
         $this->session->call($procedure, $arguments)
             ->then(
+
+                /**
+                 * @param string $res
+                 */
                 function ($res) use ($deferred, $filter) {
                     $deferred->resolve($filter($res));
                 },
@@ -228,7 +238,7 @@ 
     }
 
     /**
-     * @param $event
+     * @param string $event
      * @return \Closure
      */
     private function getSubscriptionHandler($event)

Spacing +8 added lines, -8 removed lines

@@ -82,7 +82,7 @@ 
             $this->callInitialProcedure(),
         ];
 
-        \React\Promise\all($promises)->done(function () {
+        \React\Promise\all($promises)->done(function() {
             $this->isRunning = true;
             $this->emit('start', [$this->getList()]);
         });
@@ -167,12 +167,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);
@@ -185,7 +185,7 @@ 
 
     private function getErrorCallback()
     {
-        return function ($error) {
+        return function($error) {
             $this->emit('error', [$error]);
 
             return $error;
@@ -198,13 +198,13 @@ 
             new Deferred()
         );
 
-        $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()
@@ -233,14 +233,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/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->createPromiseAdapter(function (callable $resolve) {
+        return $this->createPromiseAdapter(function(callable $resolve) {
             $resolve($this->subscriptionIds);
         });
     }