messenger 0.1.0

two way messenger
1
2
3
4
5
6
7
8
9
10
11
12
13

use futures::Stream;
use futures::sync::mpsc;

pub trait Receiver: Stream {
    fn close(&mut self);
}

impl<T> Receiver for mpsc::UnboundedReceiver<T> {
    #[inline]
    fn close(&mut self) {
        mpsc::UnboundedReceiver::close(self);
    }
}