use futures::sync::mpsc;

struct Message<T, R> {
    a: T,
    b: R,
}

#[derive(Clone)]
pub struct BusSender<T, R: Send> {
    sender: mpsc::UnboundedSender<Message<T, R>>,
}