jsonrpc/server: use queue with condvar instead of async channels

1 files changed, 6 insertions, 1 deletions

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,