tidal / WampWatch

src/Tidal/WampWatch/SessionMonitor.php

Doc Comments +11 added lines

@@ -100,8 +100,15 @@ 
     }

     

     

+    /**
+     * @param callable $callback
+     */
     protected function retrieveSessionIds($callback = null) {

         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(

+
+            /**
+             * @param callable $res
+             */
             function ($res)use($callback){

                 $this->sessionIds = $res[0];

                 $this->emit('list', [$this->sessionIds]);

@@ -109,6 +116,10 @@ 
                     $callback($this->sessionIds);

                 }

             },

+
+            /**
+             * @param callable $error
+             */
             function ($error) {

                 $this->emit('error', [$error]);

             }

Braces +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
     public function getSessionIds(callable $callback) {

         if(!count($this->sessionIds)){

             $this->retrieveSessionIds($callback);

-        }else{

+        } else{

             $callback($this->sessionIds);

         }

     }

src/Tidal/WampWatch/SubscriptionMonitor.php

Doc Comments +11 added lines

@@ -100,8 +100,15 @@ 
     }

     

     

+    /**
+     * @param callable $callback
+     */
     protected function retrieveSessionIds($callback = null) {

         $this->session->call(self::SESSION_LIST_TOPIC, [])->then(

+
+            /**
+             * @param callable $res
+             */
             function ($res)use($callback){

                 $this->sessionIds = $res[0];

                 $this->emit('list', [$this->sessionIds]);

@@ -109,6 +116,10 @@ 
                     $callback($this->sessionIds);

                 }

             },

+
+            /**
+             * @param callable $error
+             */
             function ($error) {

                 $this->emit('error', [$error]);

             }

Braces +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
     public function getSessionIds(callable $callback) {
         if(!count($this->sessionIds)){
             $this->retrieveSessionIds($callback);
-        }else{
+        } else{
             $callback($this->sessionIds);
         }
     }