pub type Subscriber<M> = UnboundedSender<Notification<M>>;
pub struct Subscriber<M> { /* private fields */ }