Trait ResultStreamExt

pub trait ResultStreamExt<T, E: Debug>: Stream<Item = Result<T, E>> {
    // Provided method
    fn filter_ok(self) -> impl Stream<Item = T>
       where Self: Sized { ... }
}

Adapters specific to Result-returning streams.

Provided Methods

fn filter_ok(self) -> impl Stream<Item = T>

where Self: Sized,

Returns a stream with filtered out Err(T) items.

Implementors

impl<S, T, E: Debug> ResultStreamExt<T, E> for S

where S: Stream<Item = Result<T, E>> + ?Sized,