Avoid calling ->done on a Ryu::Source

deriv-com · May 29, 2024 · 08551f9 · 08551f9
1 parent 6c336a6
commit 08551f9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/Myriad/RPC/Client/Implementation/Redis.pm b/lib/Myriad/RPC/Client/Implementation/Redis.pm
@@ -61,7 +61,7 @@ async method start() {
         } catch ($e) {
             $log->warnf('failed to parse rpc response due %s', $e);
         }
-    })->completed;
+    });
 
     $started->done('started');
     $log->tracef('Started RPC client subscription on %s', $whoami);
@@ -109,7 +109,7 @@ async method call_rpc($service, $method, %args) {
 }
 
 async method stop {
-    $subscription->done();
+    $subscription->finish
 }
 
 method next_id {