From a06239ccc5e21fd20182ec3046cf9174ecc58a43 Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Thu, 30 May 2024 02:07:50 +0200
Subject: jsonrpc/server: use queue with condvar instead of async channels

---
 jsonrpc/src/client/mod.rs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

(limited to 'jsonrpc/src/client')

diff --git a/jsonrpc/src/client/mod.rs b/jsonrpc/src/client/mod.rs
index 326252a..3a4505c 100644
--- a/jsonrpc/src/client/mod.rs
+++ b/jsonrpc/src/client/mod.rs
@@ -149,7 +149,12 @@ impl Client {
             async move {
                 loop {
                     let msg = selfc.conn.recv().await?;
-                    selfc.handle_msg(msg).await?;
+                    if let Err(err) = selfc.handle_msg(msg).await {
+                        error!(
+                            "Failed to handle a new received msg from the connection {} : {err}",
+                            selfc.conn.peer_endpoint()?
+                        );
+                    }
                 }
             },
             on_failure,
-- 
cgit v1.2.3