Struct par_stream::builder::ParBlockingBuilder
source · [−]pub struct ParBlockingBuilder<St, Fac, Out> where
St: ?Sized + Stream,
St::Item: 'static + Send,
Fac: FnFactory<St::Item, Out>,
Fac::Fn: 'static + Send + FnOnce() -> Out,
Out: 'static + Send, { /* private fields */ }
Expand description
The parallel stream builder with scheduled blocking tasks.
Implementations
sourceimpl<St, Fac, Out> ParBlockingBuilder<St, Fac, Out> where
St: Stream,
St::Item: 'static + Send,
Fac: 'static + Send + FnFactory<St::Item, Out>,
Fac::Fn: 'static + Send + FnOnce() -> Out,
Out: 'static + Send,
impl<St, Fac, Out> ParBlockingBuilder<St, Fac, Out> where
St: Stream,
St::Item: 'static + Send,
Fac: 'static + Send + FnFactory<St::Item, Out>,
Fac::Fn: 'static + Send + FnOnce() -> Out,
Out: 'static + Send,
sourcepub fn map_async<NewFac, NewFut>(
self,
new_fac: NewFac
) -> ParAsyncBuilder<St, ComposeFutureFactory<St::Item, impl FnMut(St::Item) -> JoinHandle<Out>, NewFac>> where
NewFac: Send + Clone + FnMut(Out) -> NewFut,
NewFut: 'static + Send + Future,
NewFut::Output: 'static + Send,
pub fn map_async<NewFac, NewFut>(
self,
new_fac: NewFac
) -> ParAsyncBuilder<St, ComposeFutureFactory<St::Item, impl FnMut(St::Item) -> JoinHandle<Out>, NewFac>> where
NewFac: Send + Clone + FnMut(Out) -> NewFut,
NewFut: 'static + Send + Future,
NewFut::Output: 'static + Send,
Schedule an asynchronous task.
sourcepub fn map_blocking<NewOut, NewFac, NewFunc>(
self,
new_fac: NewFac
) -> ParBlockingBuilder<St, BoxFnFactory<St::Item, NewOut>, NewOut> where
NewFac: 'static + Send + Clone + FnMut(Out) -> NewFunc,
NewFunc: 'static + Send + FnOnce() -> NewOut,
NewFunc::Output: 'static + Send,
pub fn map_blocking<NewOut, NewFac, NewFunc>(
self,
new_fac: NewFac
) -> ParBlockingBuilder<St, BoxFnFactory<St::Item, NewOut>, NewOut> where
NewFac: 'static + Send + Clone + FnMut(Out) -> NewFunc,
NewFunc: 'static + Send + FnOnce() -> NewOut,
NewFunc::Output: 'static + Send,
Schedule a blocking task.
sourcepub fn build_unordered_stream<P>(self, params: P) -> UnorderedStream<Out> where
St: 'static + Send,
P: Into<ParParams>,
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.
sourcepub fn build_ordered_stream<P>(self, params: P) -> OrderedStream<Out> where
St: 'static + Send,
P: Into<ParParams>,
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.
sourceimpl<St, Fac> ParBlockingBuilder<St, Fac, ()> where
St: 'static + Send + Stream,
St::Item: 'static + Send,
Fac: 'static + Send + FnFactory<St::Item, ()>,
Fac::Fn: 'static + Send + FnOnce(),
impl<St, Fac> ParBlockingBuilder<St, Fac, ()> where
St: 'static + Send + Stream,
St::Item: 'static + Send,
Fac: 'static + Send + FnFactory<St::Item, ()>,
Fac::Fn: 'static + Send + FnOnce(),
Auto Trait Implementations
impl<St: ?Sized, Fac, Out> RefUnwindSafe for ParBlockingBuilder<St, Fac, Out> where
Fac: RefUnwindSafe,
Out: RefUnwindSafe,
St: RefUnwindSafe,
impl<St: ?Sized, Fac, Out> Send for ParBlockingBuilder<St, Fac, Out> where
Fac: Send,
St: Send,
impl<St: ?Sized, Fac, Out> Sync for ParBlockingBuilder<St, Fac, Out> where
Fac: Sync,
Out: Sync,
St: Sync,
impl<St: ?Sized, Fac, Out> Unpin for ParBlockingBuilder<St, Fac, Out> where
Fac: Unpin,
Out: Unpin,
St: Unpin,
impl<St: ?Sized, Fac, Out> UnwindSafe for ParBlockingBuilder<St, Fac, Out> where
Fac: UnwindSafe,
Out: UnwindSafe,
St: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more