Trait nu_stream::Interruptible

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

Required methods

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

Loading content...

Implementors

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

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

Loading content...