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