credence-lib 0.0.6

An unfussy web server designed for straightforward authoring and scalable performance
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use {notify::*, std::result::Result, tokio::sync::mpsc::*};

/// Channel message.
pub type Message = Result<Event, Error>;

//
// SenderEventHandler
//

/// Implements [EventHandler] for [Sender].
pub struct SenderEventHandler(pub Sender<Message>);

impl EventHandler for SenderEventHandler {
    fn handle_event(&mut self, event: Message) {
        if let Err(error) = self.0.blocking_send(event) {
            tracing::error!("{}", error);
        }
    }
}