messenger 0.1.0

two way messenger
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

use futures::sync::mpsc;

pub trait Sender {
    type Item;

    fn send(&self, Self::Item) -> Result<(), Self::Item>;
}

impl<S, T> Sender for Box<S>
where
    S: ?Sized + Sender<Item = T>,
{
    type Item = T;

    #[inline]
    fn send(&self, item: Self::Item) -> Result<(), Self::Item> {
        (&**self).send(item)
    }
}

impl<T> Sender for mpsc::UnboundedSender<T> {
    type Item = T;

    #[inline]
    fn send(&self, item: Self::Item) -> Result<(), Self::Item> {
        match mpsc::UnboundedSender::unbounded_send(self, item) {
            Ok(_) => Ok(()),
            Err(e) => Err(e.into_inner()),
        }
    }
}