jsonrpc: client use unbounded channels as buffer for sending requests & clean up examples

1 files changed, 3 insertions, 1 deletions

diff --git a/jsonrpc/examples/pubsub_client.rs b/jsonrpc/examples/pubsub_client.rs
index 830b32f..73570b8 100644
--- a/jsonrpc/examples/pubsub_client.rs
+++ b/jsonrpc/examples/pubsub_client.rs
@@ -1,5 +1,6 @@
 use std::time::Duration;
 
+use log::info;
 use serde::{Deserialize, Serialize};
 use smol::Timer;
 
@@ -25,7 +26,8 @@ async fn run_client() {
 
     smol::spawn(async move {
         loop {
-            let _m = sub.recv().await.unwrap();
+            let m = sub.recv().await.expect("Receive new log msg");
+            info!("Receive new log {m}");
         }
     })
     .detach();