diff options
Diffstat (limited to 'p2p/src/backend.rs')
-rw-r--r-- | p2p/src/backend.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/p2p/src/backend.rs b/p2p/src/backend.rs index 2f21b3e..c05a693 100644 --- a/p2p/src/backend.rs +++ b/p2p/src/backend.rs @@ -2,13 +2,13 @@ use std::sync::Arc; use log::info; -use karyon_core::{async_runtime::Executor, crypto::KeyPair, pubsub::Subscription}; +use karyon_core::{async_runtime::Executor, crypto::KeyPair}; use crate::{ config::Config, connection::ConnQueue, discovery::{ArcDiscovery, Discovery}, - monitor::{Monitor, MonitorEvent}, + monitor::Monitor, peer_pool::PeerPool, protocol::{ArcProtocol, Protocol}, ArcPeer, PeerID, Result, @@ -112,9 +112,9 @@ impl Backend { self.discovery.outbound_slots.load() } - /// Subscribes to the monitor to receive network events. - pub async fn monitor(&self) -> Subscription<MonitorEvent> { - self.monitor.subscribe().await + /// Returns the monitor to receive system events. + pub fn monitor(&self) -> Arc<Monitor> { + self.monitor.clone() } /// Shuts down the Backend. |