tidal / WampWatch

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;