Function mpsc_unbounded_toggle 

pub fn mpsc_unbounded_toggle<C>(
    cancel: C,
) -> (Arc<AtomicBool>, UnboundedSender<()>)
where
    C: Future + Send + 'static,