diff options
author | hozan23 <hozan23@karyontech.net> | 2024-07-15 13:28:00 +0200 |
---|---|---|
committer | hozan23 <hozan23@karyontech.net> | 2024-07-15 13:28:00 +0200 |
commit | dc4c448e597b08cba4c79c194b0c1aa517daab29 (patch) | |
tree | 5ec8a2585cac2bbe7e4c54150b0f3f2f556f5399 /p2p/src/monitor | |
parent | e15d3e6fd20b3f87abaad7ddec1c88b0e66419f9 (diff) |
core: rename EventSys to EventEmitter
Diffstat (limited to 'p2p/src/monitor')
-rw-r--r-- | p2p/src/monitor/mod.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/p2p/src/monitor/mod.rs b/p2p/src/monitor/mod.rs index 86db23e..cbd492a 100644 --- a/p2p/src/monitor/mod.rs +++ b/p2p/src/monitor/mod.rs @@ -4,7 +4,7 @@ use std::sync::Arc; use log::error; -use karyon_core::event::{EventListener, EventSys, EventValue, EventValueTopic}; +use karyon_core::event::{EventEmitter, EventListener, EventValue, EventValueTopic}; use karyon_net::Endpoint; @@ -47,7 +47,7 @@ use crate::{Config, PeerID}; /// }; /// ``` pub struct Monitor { - event_sys: Arc<EventSys<MonitorTopic>>, + event_emitter: Arc<EventEmitter<MonitorTopic>>, config: Arc<Config>, } @@ -55,7 +55,7 @@ impl Monitor { /// Creates a new Monitor pub(crate) fn new(config: Arc<Config>) -> Self { Self { - event_sys: EventSys::new(), + event_emitter: EventEmitter::new(), config, } } @@ -64,7 +64,7 @@ impl Monitor { pub(crate) async fn notify<E: ToEventStruct>(&self, event: E) { if self.config.enable_monitor { let event = event.to_struct(); - if let Err(err) = self.event_sys.emit(&event).await { + if let Err(err) = self.event_emitter.emit(&event).await { error!("Failed to notify monitor event {:?}: {err}", event); } } @@ -75,7 +75,7 @@ impl Monitor { where E: Clone + EventValue + EventValueTopic<Topic = MonitorTopic>, { - self.event_sys.register(&E::topic()).await + self.event_emitter.register(&E::topic()).await } } |