Trait Interruptible 

pub trait Interruptible<V> {
    // Required method
    fn interruptible(self, ctrl_c: Arc<AtomicBool>) -> InterruptibleStream<V> ;
}

Required Methods

fn interruptible(self, ctrl_c: Arc<AtomicBool>) -> InterruptibleStream<V>

Implementors

impl<S, V> Interruptible<V> for S

where S: Iterator<Item = V> + Send + Sync + 'static,