pub fn stop(&self) {
        let mut lock = self.0.write().unwrap();
        if !lock.stopped {
            lock.stopped = true;
            lock.waker.notify_all();
        }
    }
/// Stop all futures and streams that have been registered to this
/// Stopper or any clone representing the same initial stopper.
///
Stop all futures and streams that have been registered to this
Stopper or any clone representing the same initial stopper.
Stop all futures and streams that have been registered to this Stopper or any clone representing the same initial stopper .
pub fn stop(&self) {
        let mut lock = self.0.write().unwrap();
        if !lock.stopped {
            lock.stopped = true;
            lock.waker.notify_all();
        }
    }
pub fn stop ( & self ) { let mut lock = self . 0 . write ( ) . unwrap ( ) ; if ! lock . stopped { lock . stopped = true ; lock . waker . notify_all ( ) ; } }
Stop all futures and streams that have been registered to this
Stopper or any clone representing the same initial stopper.
Stop all futures and streams that have been registered to this Stopper or any clone representing the same initial stopper .
&self
&self