Struct par_stream::builder::ParBuilder
source · [−]pub struct ParBuilder<St> where
St: ?Sized + Stream, { /* private fields */ }
Expand description
Parallel stream builder created by par_builder.
Implementations
sourceimpl<St> ParBuilder<St> where
St: Stream,
impl<St> ParBuilder<St> where
St: Stream,
sourcepub fn map_async<Fut, Fac>(self, fac: Fac) -> ParAsyncBuilder<St, Fac> where
St::Item: Send,
Fac: 'static + Send + FnMut(St::Item) -> Fut,
Fut: 'static + Send + Future,
Fut::Output: Send,
pub fn map_async<Fut, Fac>(self, fac: Fac) -> ParAsyncBuilder<St, Fac> where
St::Item: Send,
Fac: 'static + Send + FnMut(St::Item) -> Fut,
Fut: 'static + Send + Future,
Fut::Output: Send,
Schedules an asynchronous task.
sourcepub fn map_blocking<Fac, Func, Out>(
self,
fac: Fac
) -> ParBlockingBuilder<St, Fac, Out> where
St::Item: 'static + Send,
Fac: 'static + Send + FnMut(St::Item) -> Func,
Func: 'static + Send + FnOnce() -> Out,
Out: Send,
pub fn map_blocking<Fac, Func, Out>(
self,
fac: Fac
) -> ParBlockingBuilder<St, Fac, Out> where
St::Item: 'static + Send,
Fac: 'static + Send + FnMut(St::Item) -> Func,
Func: 'static + Send + FnOnce() -> Out,
Out: Send,
Schedules a blocking task.
Auto Trait Implementations
impl<St: ?Sized> RefUnwindSafe for ParBuilder<St> where
St: RefUnwindSafe,
impl<St: ?Sized> Send for ParBuilder<St> where
St: Send,
impl<St: ?Sized> Sync for ParBuilder<St> where
St: Sync,
impl<St: ?Sized> Unpin for ParBuilder<St> where
St: Unpin,
impl<St: ?Sized> UnwindSafe for ParBuilder<St> where
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