Trait FbTryStreamExt 

pub trait FbTryStreamExt: TryStream {
    // Provided methods
    fn try_buffered_weight_limited<'a, I, Fut, E>(
        self,
        params: BufferedParams,
    ) -> WeightLimitedBufferedTryStream<'a, Self, I, E>
       where Self: Sized + Send + 'a + TryStream<Ok = (Fut, u64), Error = E>,
             Fut: TryFuture<Ok = I, Error = E> { ... }
    fn flatten_err<I, E1, E2>(
        self,
    ) -> Map<Self, fn(Result<Result<I, E1>, E2>) -> Result<I, E1>>
       where Self: Sized + Stream<Item = Result<Result<I, E1>, E2>>,
             E1: From<E2> { ... }
}

A trait implemented by default for all TryStreams which extends the standard functionality.

Provided Methods

fn try_buffered_weight_limited<'a, I, Fut, E>( self, params: BufferedParams, ) -> WeightLimitedBufferedTryStream<'a, Self, I, E>

where Self: Sized + Send + 'a + TryStream<Ok = (Fut, u64), Error = E>, Fut: TryFuture<Ok = I, Error = E>,

Like futures::stream::StreamExt::buffered call, but for TryStream and can also limit number of futures in a buffer by “weight”.

fn flatten_err<I, E1, E2>( self, ) -> Map<Self, fn(Result<Result<I, E1>, E2>) -> Result<I, E1>>

where Self: Sized + Stream<Item = Result<Result<I, E1>, E2>>, E1: From<E2>,

Convert a Stream of Result<Result<I, E1>, E2> into a Stream of Result<I, E1>, assuming E2 can convert into E1.

Implementors

impl<T> FbTryStreamExt for T

where T: TryStream + ?Sized,