From 08551f94d733007d3339725a529acd067d793c8d Mon Sep 17 00:00:00 2001
From: Tom Molesworth <tom@deriv.com>
Date: Thu, 30 May 2024 00:53:16 +0800
Subject: [PATCH] Avoid calling ->done on a Ryu::Source

---
 lib/Myriad/RPC/Client/Implementation/Redis.pm | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/Myriad/RPC/Client/Implementation/Redis.pm b/lib/Myriad/RPC/Client/Implementation/Redis.pm
index 4b875cf8..5839b142 100644
--- 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 {