View GitHub Repository WampWatch

Schedule Inspection
Subscribe
Completed
Pull Request — master (#42)
by Timo
02:15
created
Status
Category
Toggle Patches
src/Tidal/WampWatch/SubscriptionMonitor.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch 
@@ -61,7 +61,7 @@  discard block
 
 block discarded – undo
61 61 
     public function getSubscriptionInfo($topic)
62 62 
     {
63 63 
         return $this->session->call(self::SUBSCRIPTION_GET_TOPIC, [$topic])->then(
64 
-            function ($res) {
64 
+            function($res) {
65 65 
                 $this->emit('info', [$res]);
66 66
67 67 
                 return $res;
 
@@ -76,7 +76,7 @@  discard block
 
 block discarded – undo
76 76 
             return $this->retrieveSubscriptionIds();
77 77 
         }
78 78
79 
-        return new Promise(function (callable $resolve) {
79 
+        return new Promise(function(callable $resolve) {
80 80 
             $resolve($this->subscriptionIds);
81 81 
         });
82 82 
     }
 
@@ -99,7 +99,7 @@  discard block
 
 block discarded – undo
99 99
100 100 
     private function getCreateHandler()
101 101 
     {
102 
-        return function ($res) {
102 
+        return function($res) {
103 103 
             $sessionId = $res[0];
104 104 
             $subscriptionInfo = $res[1];
105 105 
             $this->emit('create', [$sessionId, $subscriptionInfo]);
 
@@ -108,7 +108,7 @@  discard block
 
 block discarded – undo
108 108
109 109 
     private function getSubscriptionHandler($event)
110 110 
     {
111 
-        return function ($res) use ($event) {
111 
+        return function($res) use ($event) {
112 112 
             $sessionId = $res[0];
113 113 
             $subscriptionId = $res[1];
114 114 
             $this->emit($event, [$sessionId, $subscriptionId]);
 
@@ -136,7 +136,7 @@  discard block
 
 block discarded – undo
136 136
137 137 
     protected function getSubscriptionIdRetrievalCallback()
138 138 
     {
139 
-        return function (\Thruway\CallResult $res) {
139 
+        return function(\Thruway\CallResult $res) {
140 140 
             /** @var \Thruway\Message\ResultMessage $message */
141 141 
             $message = $res->getResultMessage();
142 142 
             $list = $message->getArguments()[0];
Please login to merge, or discard this patch.