Trait TryWidebandExt 

pub trait TryWidebandExt<T, E>
where
    Self: TryStream<Ok = T, Error = E, Item = Result<T, E>> + Send + Sized,
{
    // Required method
    fn widen_and_then<U, F, Fut, N>(
        self,
        n: N,
        f: F,
    ) -> impl TryStream<Ok = U, Error = E, Item = Result<U, E>> + Send
       where N: Into<Option<usize>>,
             F: Fn(Self::Ok) -> Fut + Send,
             Fut: TryFuture<Ok = U, Error = E, Output = Result<U, E>> + Send,
             U: Send;

    // Provided method
    fn wide_and_then<U, F, Fut>(
        self,
        f: F,
    ) -> impl TryStream<Ok = U, Error = E, Item = Result<U, E>> + Send
       where F: Fn(Self::Ok) -> Fut + Send,
             Fut: TryFuture<Ok = U, Error = E, Output = Result<U, E>> + Send,
             U: Send { ... }
}

Concurrency extensions to augment futures::TryStreamExt. wide_ combinators produce in-order results

Required Methods

fn widen_and_then<U, F, Fut, N>( self, n: N, f: F, ) -> impl TryStream<Ok = U, Error = E, Item = Result<U, E>> + Send

where N: Into<Option<usize>>, F: Fn(Self::Ok) -> Fut + Send, Fut: TryFuture<Ok = U, Error = E, Output = Result<U, E>> + Send, U: Send,

Provided Methods

fn wide_and_then<U, F, Fut>( self, f: F, ) -> impl TryStream<Ok = U, Error = E, Item = Result<U, E>> + Send

where F: Fn(Self::Ok) -> Fut + Send, Fut: TryFuture<Ok = U, Error = E, Output = Result<U, E>> + Send, U: Send,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<T, E, S> TryWidebandExt<T, E> for S

where S: TryStream<Ok = T, Error = E, Item = Result<T, E>> + Send + Sized, E: Send,