Trait nu_stream::Interruptible [−][src]
Required methods
fn interruptible(self, ctrl_c: Arc<AtomicBool>) -> InterruptibleStream<V>
[src]
Implementors
impl<S, V> Interruptible<V> for S where
S: Stream<Item = V> + Send + 'static,
[src]
S: Stream<Item = V> + Send + 'static,