speare 0.4.3

actor-like thin abstraction over tokio::task and flume channels
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use flume::Sender;

pub trait OnErrTerminate<E>: Send + 'static {
    fn on_err_terminate(&self, err: &E);
}

pub struct NoWatch;

impl<E> OnErrTerminate<E> for NoWatch {
    fn on_err_terminate(&self, _err: &E) {}
}

pub struct WatchFn<F, Msg> {
    pub f: F,
    pub parent_msg_tx: Sender<Msg>,
}

impl<F, E, Msg> OnErrTerminate<E> for WatchFn<F, Msg>
where
    F: Fn(&E) -> Msg + Send + 'static,
    Msg: Send + 'static,
{
    fn on_err_terminate(&self, err: &E) {
        let msg = (self.f)(err);
        let _ = self.parent_msg_tx.send(msg);
    }
}