diff options
| author | hozan23 <hozan23@karyontech.net> | 2024-06-14 22:49:53 +0200 |
|---|---|---|
| committer | hozan23 <hozan23@karyontech.net> | 2024-06-14 22:49:53 +0200 |
| commit | 3429caa87699d986f799a11f6e0f4526e723b655 (patch) | |
| tree | e548c356fca4eb76742e29d4bab05007468ed14b /jsonrpc/src/server/channel.rs | |
| parent | 0c0699c0460c1b149915729223eec701bde481df (diff) | |
jsonrpc: client use unbounded channels as buffer for sending requests & clean up examples
Diffstat (limited to 'jsonrpc/src/server/channel.rs')
| -rw-r--r-- | jsonrpc/src/server/channel.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jsonrpc/src/server/channel.rs b/jsonrpc/src/server/channel.rs index 9278c8c..b5c9184 100644 --- a/jsonrpc/src/server/channel.rs +++ b/jsonrpc/src/server/channel.rs @@ -4,6 +4,7 @@ use karyon_core::{async_runtime::lock::Mutex, util::random_32}; use crate::{message::SubscriptionID, Error, Result}; +#[derive(Debug)] pub(crate) struct NewNotification { pub sub_id: SubscriptionID, pub result: serde_json::Value, @@ -20,7 +21,7 @@ pub struct Subscription { } impl Subscription { - /// Creates a new `Subscription` + /// Creates a new [`Subscription`] fn new( parent: Arc<Channel>, id: SubscriptionID, |