Trait nu_stream::Interruptible

source · [−]

pub trait Interruptible<V> {
    fn interruptible(self, ctrl_c: Arc<AtomicBool>) -> InterruptibleStream<V>ⓘNotable traits for InterruptibleStream<V>
impl<V> Iterator for InterruptibleStream<V>    type Item = V;;
}

Required methods

fn interruptible(self, ctrl_c: Arc<AtomicBool>) -> InterruptibleStream<V>ⓘ
Notable traits for InterruptibleStream<V>
`impl<V> Iterator for InterruptibleStream<V> type Item = V;`

Implementors

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