From e16204496bd3c47a1dcd66d56fa9eada40c18b89 Mon Sep 17 00:00:00 2001 From: ghassmo Date: Fri, 13 May 2022 11:47:49 +0300 Subject: [PATCH] rpcclient: add close connection function --- src/rpc/rpcclient.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/rpc/rpcclient.rs b/src/rpc/rpcclient.rs index 05fdbae1e..f10d9e11f 100644 --- a/src/rpc/rpcclient.rs +++ b/src/rpc/rpcclient.rs @@ -18,6 +18,11 @@ impl RpcClient { Ok(Self { sender, receiver, stop_signal }) } + pub async fn close(&self) -> Result<()> { + self.stop_signal.send(()).await?; + Ok(()) + } + pub async fn request(&self, value: JsonRequest) -> Result { let req_id = value.id.clone().as_u64().unwrap_or(0); let value = json!(value);