diff options
| author | hozan23 <hozan23@karyontech.net> | 2024-06-14 02:04:43 +0200 |
|---|---|---|
| committer | hozan23 <hozan23@karyontech.net> | 2024-06-14 02:04:43 +0200 |
| commit | 0c0699c0460c1b149915729223eec701bde481df (patch) | |
| tree | b9ada7e1bd288684eb8fdf690ea1034520ab9f16 /jsonrpc/src | |
| parent | 60a947f6e857f0aa5ae5e8c3b0a183577f74a9f4 (diff) | |
p2p: WIP implement rpc server for the p2p monitor
Diffstat (limited to 'jsonrpc/src')
| -rw-r--r-- | jsonrpc/src/client/mod.rs | 2 | ||||
| -rw-r--r-- | jsonrpc/src/server/channel.rs | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/jsonrpc/src/client/mod.rs b/jsonrpc/src/client/mod.rs index 95354d3..1225f13 100644 --- a/jsonrpc/src/client/mod.rs +++ b/jsonrpc/src/client/mod.rs @@ -97,6 +97,7 @@ impl Client { // Send the json request self.conn.send(req_json).await?; + debug!("--> {request}"); // Register a new request let rx = self.message_dispatcher.register(id).await; @@ -126,7 +127,6 @@ impl Client { return Err(Error::InvalidMsg("Invalid response id")); } - debug!("--> {request}"); Ok(response) } diff --git a/jsonrpc/src/server/channel.rs b/jsonrpc/src/server/channel.rs index bb62b9f..9278c8c 100644 --- a/jsonrpc/src/server/channel.rs +++ b/jsonrpc/src/server/channel.rs @@ -11,6 +11,7 @@ pub(crate) struct NewNotification { } /// Represents a new subscription +#[derive(Clone)] pub struct Subscription { pub id: SubscriptionID, parent: Arc<Channel>, |