diff --git a/noxis-rs/src/utils/services.rs b/noxis-rs/src/utils/services.rs index f5d8ff1..a381cb1 100644 --- a/noxis-rs/src/utils/services.rs +++ b/noxis-rs/src/utils/services.rs @@ -16,7 +16,7 @@ pub mod v2 { type MpscSender = Arc>; // type EventHandlers<'a> = Vec>>; - type EventHandlers = HashMap; + type EventHandlers = HashMap, (Triggers, MpscSender)>; // type wrapper for service wait queue type ConnectionQueue = BTreeMap>>; @@ -92,7 +92,7 @@ pub mod v2 { }); } // event add - self.event_registrator.entry(proc_name.to_string()).or_insert((trigger, sender)); + self.event_registrator.entry(proc_name).or_insert((trigger, sender)); } async fn check_state(&self) -> anyhow::Result<()> { let mut addrs = self.access_url.to_socket_addrs()?; @@ -148,7 +148,7 @@ pub mod v2 { for name in iterator { let proc_name = name.to_string(); info!("Trying to notify process `{}` ...", &proc_name); - let sender_opt = self.event_registrator.get(&proc_name) + let sender_opt = self.event_registrator.get(&name) .map(|(trigger, sender)| (trigger.to_service_negative_event(name.clone()), sender) );