Trait WidebandExt 

pub trait WidebandExt<Item>
where
    Self: Stream<Item = Item> + Send + Sized,
{
    // Required methods
    fn widen_filter_map<F, Fut, U, N>(
        self,
        n: N,
        f: F,
    ) -> impl Stream<Item = U> + Send
       where N: Into<Option<usize>>,
             F: Fn(Item) -> Fut + Send,
             Fut: Future<Output = Option<U>> + Send,
             U: Send;
    fn widen_then<F, Fut, U, N>(
        self,
        n: N,
        f: F,
    ) -> impl Stream<Item = U> + Send
       where N: Into<Option<usize>>,
             F: Fn(Item) -> Fut + Send,
             Fut: Future<Output = U> + Send,
             U: Send;

    // Provided methods
    fn wide_filter_map<F, Fut, U>(self, f: F) -> impl Stream<Item = U> + Send
       where F: Fn(Item) -> Fut + Send,
             Fut: Future<Output = Option<U>> + Send,
             U: Send { ... }
    fn wide_then<F, Fut, U>(self, f: F) -> impl Stream<Item = U> + Send
       where F: Fn(Item) -> Fut + Send,
             Fut: Future<Output = U> + Send,
             U: Send { ... }
}

Concurrency extensions to augment futures::StreamExt. wideband_ combinators produce in-order.

Required Methods

fn widen_filter_map<F, Fut, U, N>( self, n: N, f: F, ) -> impl Stream<Item = U> + Send

where N: Into<Option<usize>>, F: Fn(Item) -> Fut + Send, Fut: Future<Output = Option<U>> + Send, U: Send,

Concurrent filter_map(); ordered results

fn widen_then<F, Fut, U, N>(self, n: N, f: F) -> impl Stream<Item = U> + Send

where N: Into<Option<usize>>, F: Fn(Item) -> Fut + Send, Fut: Future<Output = U> + Send, U: Send,

Provided Methods

fn wide_filter_map<F, Fut, U>(self, f: F) -> impl Stream<Item = U> + Send

where F: Fn(Item) -> Fut + Send, Fut: Future<Output = Option<U>> + Send, U: Send,

fn wide_then<F, Fut, U>(self, f: F) -> impl Stream<Item = U> + Send

where F: Fn(Item) -> Fut + Send, Fut: Future<Output = U> + 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<Item, S> WidebandExt<Item> for S

where S: Stream<Item = Item> + Send + Sized,