wip

laravel · May 8, 2024 · 8bf09be · 8bf09be
1 parent 32af5f8
commit 8bf09be
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/Protocols/Pusher/MetricsHandler.php b/src/Protocols/Pusher/MetricsHandler.php
@@ -212,7 +212,7 @@ protected function mergeChannels(array $metrics): array
     protected function listenForMetrics(string $key): Deferred
     {
         dump('Listenting on '.$key);
-        
+
         $deferred = new Deferred;
 
         $this->pubSubProvider->on('metrics-retrieved', function ($payload) use ($key, $deferred) {

diff --git a/src/Servers/Reverb/Publishing/RedisPubSubProvider.php b/src/Servers/Reverb/Publishing/RedisPubSubProvider.php
@@ -63,6 +63,7 @@ public function subscribe(): void
      */
     public function on(string $event, callable $callback): void
     {
+        dump('Listening from provider...');
         $this->subscribingClient->on('message', function (string $channel, string $payload) use ($event, $callback) {
             dump($payload);
             $payload = json_decode($payload, associative: true, flags: JSON_THROW_ON_ERROR);
@@ -71,6 +72,7 @@ public function on(string $event, callable $callback): void
                 $callback($payload);
             }
         });
+        dump('Listening from provider...done');
     }
 
     /**