Trait CoTryStreamExt 

pub trait CoTryStreamExt: Stream<Item = Result<Self::Ok, Self::Error>> {
    type Ok;
    type Error;

    // Provided methods
    fn try_first<'async_trait>(
        self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Ok>, Self::Error>> + Send + 'async_trait>>
       where Self: Sized + Send + 'async_trait { ... }
    fn try_ignore_elements<T>(self) -> TryIgnoreElements<Self, T>
       where Self: Sized { ... }
}

Required Associated Types

type Ok

type Error

Provided Methods

fn try_first<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Ok>, Self::Error>> + Send + 'async_trait>>

where Self: Sized + Send + 'async_trait,

fn try_ignore_elements<T>(self) -> TryIgnoreElements<Self, T>

where Self: Sized,

Ignore all elements by only forwarding errors.

Implementors

impl<S, T, E> CoTryStreamExt for S

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

type Ok = T

type Error = E