Struct ParAsyncTailBlockBuilder 

pub struct ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out>
where
    St: ?Sized + Stream,
    St::Item: 'static + Send,
    FutFac: FutureFactory<St::Item>,
    FutFac::Fut: 'static + Send + Future,
    <FutFac::Fut as Future>::Output: Send,
    FnFac: FnFactory<<FutFac::Fut as Future>::Output, Out>,
    FnFac::Fn: 'static + Send + FnOnce() -> Out,
    Out: 'static + Send,
{ /* private fields */ }

The parallel stream builder with scheduled asynchronous tasks and a blocking task in the end.

Implementations

impl<St, FutFac, FnFac, Out> ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out>

where St: Stream, St::Item: 'static + Send, FutFac: 'static + Send + FutureFactory<St::Item>, FutFac::Fut: 'static + Send + Future, <FutFac::Fut as Future>::Output: 'static + Send, FnFac: 'static + Send + Clone + FnFactory<<FutFac::Fut as Future>::Output, Out>, FnFac::Fn: 'static + Send + FnOnce() -> Out, Out: 'static + Send,

pub fn map_async<NewFac, NewFut>( self, new_fac: NewFac, ) -> ParAsyncBuilder<St, BoxFutureFactory<'static, St::Item, NewFut::Output>>

where NewFac: 'static + Send + Clone + FnMut(Out) -> NewFut, NewFut: 'static + Send + Future, NewFut::Output: 'static + Send,

Schedule an asynchronous task.

pub fn map_blocking<NewOut, NewFac, NewFunc>( self, new_fac: NewFac, ) -> ParAsyncTailBlockBuilder<St, FutFac, BoxFnFactory<<FutFac::Fut as Future>::Output, NewOut>, NewOut>

where NewFac: 'static + Send + Clone + FnMut(Out) -> NewFunc, NewFunc: 'static + Send + FnOnce() -> NewOut, NewFunc::Output: 'static + Send,

Schedule a blocking task.

pub fn build_unordered_stream<P>(self, params: P) -> UnorderedStream<Out>

where St: 'static + Send, P: Into<ParParams>,

Creates a stream that runs scheduled parallel tasks, which output does not respect the input order.

pub fn build_ordered_stream<P>(self, params: P) -> OrderedStream<Out>

where St: 'static + Send, P: Into<ParParams>,

Creates a stream that runs scheduled parallel tasks, which output respects the input order.

impl<St, FutFac, FnFac> ParAsyncTailBlockBuilder<St, FutFac, FnFac, ()>

where St: 'static + Send + Stream, St::Item: 'static + Send, FutFac: 'static + Send + FutureFactory<St::Item>, FutFac::Fut: 'static + Send + Future, <FutFac::Fut as Future>::Output: 'static + Send, FnFac: 'static + Send + Clone + FnFactory<<FutFac::Fut as Future>::Output, ()>, FnFac::Fn: 'static + Send + FnOnce(),

pub async fn for_each<P>(self, params: P)

where P: Into<ParParams>,

Runs parallel tasks on each stream item.