aboutsummaryrefslogtreecommitdiff
path: root/p2p/src/monitor
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-07-15 13:28:00 +0200
committerhozan23 <hozan23@karyontech.net>2024-07-15 13:28:00 +0200
commitdc4c448e597b08cba4c79c194b0c1aa517daab29 (patch)
tree5ec8a2585cac2bbe7e4c54150b0f3f2f556f5399 /p2p/src/monitor
parente15d3e6fd20b3f87abaad7ddec1c88b0e66419f9 (diff)
core: rename EventSys to EventEmitter
Diffstat (limited to 'p2p/src/monitor')
-rw-r--r--p2p/src/monitor/mod.rs10
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
}
}