diff --git a/src/Tidal/WampWatch/MonitorTrait.php b/src/Tidal/WampWatch/MonitorTrait.php index 7699a95..3ab62b8 100644 --- a/src/Tidal/WampWatch/MonitorTrait.php +++ b/src/Tidal/WampWatch/MonitorTrait.php @@ -137,7 +137,7 @@ protected function getSubscriptionCollection() protected function setInitialCall($pocedure, callable $callback) { - $this->initialCallProcedure = (string)$pocedure; + $this->initialCallProcedure = (string) $pocedure; $this->initialCallCallback = $callback; } diff --git a/src/Tidal/WampWatch/Subscription/Collection.php b/src/Tidal/WampWatch/Subscription/Collection.php index 04114c5..7a08f2d 100644 --- a/src/Tidal/WampWatch/Subscription/Collection.php +++ b/src/Tidal/WampWatch/Subscription/Collection.php @@ -96,7 +96,6 @@ protected function doSubscribe() foreach (array_keys($this->subscriptions) as $topic) { $this->session->subscribe($topic, $this->subscriptionCallbacks[$topic]) ->done(function (SubscribedMessage $msg) use ($topic) { - $this->subscriptions[$topic] = $msg->getSubscriptionId(); $this->subscriptionPromise->notify($topic);