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/server/channel.rs | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

(limited to 'jsonrpc/src/server/channel.rs')

diff --git a/jsonrpc/src/server/channel.rs b/jsonrpc/src/server/channel.rs
index efcd344..a9d1002 100644
--- a/jsonrpc/src/server/channel.rs
+++ b/jsonrpc/src/server/channel.rs
@@ -59,7 +59,7 @@ pub struct Channel {
 }
 
 impl Channel {
-    /// Creates a new `Channel`
+    /// Creates a new [`Channel`]
     pub(crate) fn new(chan: async_channel::Sender<NewNotification>) -> ArcChannel {
         Arc::new(Self {
             chan,
@@ -67,7 +67,7 @@ impl Channel {
         })
     }
 
-    /// Creates a new subscription
+    /// Creates a new [`Subscription`]
     pub async fn new_subscription(self: &Arc<Self>, method: &str) -> Subscription {
         let sub_id = random_32();
         let sub = Subscription::new(self.clone(), sub_id, self.chan.clone(), method);
@@ -76,7 +76,7 @@ impl Channel {
     }
 
     /// Removes a subscription
-    pub async fn remove_subscription(self: &Arc<Self>, id: &SubscriptionID) {
+    pub async fn remove_subscription(&self, id: &SubscriptionID) {
         let mut subs = self.subs.lock().await;
         let i = match subs.iter().position(|i| i == id) {
             Some(i) => i,
@@ -84,4 +84,8 @@ impl Channel {
         };
         subs.remove(i);
     }
+
+    pub fn close(&self) {
+        self.chan.close();
+    }
 }
-- 
cgit v1.2.3