Function mpsc_toggle 

pub fn mpsc_toggle<C>(buffer: usize, cancel: C) -> (Arc<AtomicBool>, Sender<()>)
where
    C: Future + Send + 'static,