meslin 0.0.4

Ergonomic messaging for Rust
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
28
29
30
31
32
33
34
35
36
37
38
39

use crate::*;

/// A [`Message`] with input `A`, returning a response `B`.
///
/// This implements [`Message`] with [`oneshot::Receiver`] as output.
#[derive(Debug)]
pub struct Request<A, B> {
    pub msg: A,
    pub tx: ::oneshot::Sender<B>,
}

/// Re-export of [`oneshot::Receiver`](::oneshot::Receiver).
pub use ::oneshot::Receiver;
/// Re-export of [`oneshot::Sender`](::oneshot::Sender).
pub use ::oneshot::Sender;

impl<A, B> Request<A, B> {
    pub fn new(msg: A) -> (Self, ::oneshot::Receiver<B>) {
        let (sender, receiver) = ::oneshot::channel();
        (Self { msg, tx: sender }, receiver)
    }
}

impl<A, B> Message for Request<A, B>
where
    A: Send + 'static,
    B: Send + 'static,
{
    type Input = A;
    type Output = ::oneshot::Receiver<B>;

    fn create(input: Self::Input) -> (Self, Self::Output) {
        Self::new(input)
    }

    fn cancel(self, _: Self::Output) -> Self::Input {
        self.msg
    }
}