credence_lib/coordinator/
event.rs

1use {notify::*, std::result::Result, tokio::sync::mpsc::*};
2
3/// Channel message.
4pub type Message = Result<Event, Error>;
5
6//
7// SenderEventHandler
8//
9
10/// Implements [EventHandler] for [Sender].
11pub struct SenderEventHandler(pub Sender<Message>);
12
13impl EventHandler for SenderEventHandler {
14    fn handle_event(&mut self, event: Message) {
15        if let Err(error) = self.0.blocking_send(event) {
16            tracing::error!("{}", error);
17        }
18    }
19}