Struct par_stream::builder::ParAsyncTailBlockBuilder

source · [−]

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 */ }

Expand description

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

Implementations

source

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,

source

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.

source

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.

source

pub fn build_unordered_stream(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.

source

pub fn build_ordered_stream(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.

source

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(),

source

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

Runs parallel tasks on each stream item.

Auto Trait Implementations

impl<St: ?Sized, FutFac, FnFac, Out> RefUnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
 FnFac: RefUnwindSafe,
 FutFac: RefUnwindSafe,
 Out: RefUnwindSafe,
 St: RefUnwindSafe,

impl<St: ?Sized, FutFac, FnFac, Out> Send for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
 FnFac: Send,
 FutFac: Send,
 St: Send,

impl<St: ?Sized, FutFac, FnFac, Out> Sync for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
 FnFac: Sync,
 FutFac: Sync,
 Out: Sync,
 St: Sync,

impl<St: ?Sized, FutFac, FnFac, Out> Unpin for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
 FnFac: Unpin,
 FutFac: Unpin,
 Out: Unpin,
 St: Unpin,

impl<St: ?Sized, FutFac, FnFac, Out> UnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
 FnFac: UnwindSafe,
 FutFac: UnwindSafe,
 Out: UnwindSafe,
 St: UnwindSafe,

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Performs the conversion.

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

impl<T> Pointable for T

pub const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

pub unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct par_stream::builder::ParAsyncTailBlockBuilder

Implementations

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,

pub fn build_unordered_stream<P>(self, params: P) -> UnorderedStream<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>,

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

Auto Trait Implementations

impl<St: ?Sized, FutFac, FnFac, Out> RefUnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
    FnFac: RefUnwindSafe,
    FutFac: RefUnwindSafe,
    Out: RefUnwindSafe,
    St: RefUnwindSafe,

impl<St: ?Sized, FutFac, FnFac, Out> Send for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
    FnFac: Send,
    FutFac: Send,
    St: Send,

impl<St: ?Sized, FutFac, FnFac, Out> Sync for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
    FnFac: Sync,
    FutFac: Sync,
    Out: Sync,
    St: Sync,

impl<St: ?Sized, FutFac, FnFac, Out> Unpin for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
    FnFac: Unpin,
    FutFac: Unpin,
    Out: Unpin,
    St: Unpin,

impl<St: ?Sized, FutFac, FnFac, Out> UnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
    FnFac: UnwindSafe,
    FutFac: UnwindSafe,
    Out: UnwindSafe,
    St: UnwindSafe,

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where
T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where
T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where
U: From<T>,

pub fn into(self) -> U

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct par_stream::builder::ParAsyncTailBlockBuilder

Implementations

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,

pub fn build_unordered_stream<P>(self, params: P) -> UnorderedStream<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>,

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

Auto Trait Implementations

impl<St: ?Sized, FutFac, FnFac, Out> RefUnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where FnFac: RefUnwindSafe, FutFac: RefUnwindSafe, Out: RefUnwindSafe, St: RefUnwindSafe,

impl<St: ?Sized, FutFac, FnFac, Out> Send for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where FnFac: Send, FutFac: Send, St: Send,

impl<St: ?Sized, FutFac, FnFac, Out> Sync for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where FnFac: Sync, FutFac: Sync, Out: Sync, St: Sync,

impl<St: ?Sized, FutFac, FnFac, Out> Unpin for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where FnFac: Unpin, FutFac: Unpin, Out: Unpin, St: Unpin,

impl<St: ?Sized, FutFac, FnFac, Out> UnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where FnFac: UnwindSafe, FutFac: UnwindSafe, Out: UnwindSafe, St: UnwindSafe,

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> Pointable for T

pub const ALIGN: usize

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize

pub unsafe fn deref<'a>(ptr: usize) -> &'a T

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

pub unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

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,

pub fn build_unordered_stream<P>(self, params: P) -> UnorderedStream<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>,

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

impl<St: ?Sized, FutFac, FnFac, Out> RefUnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
FnFac: RefUnwindSafe,
FutFac: RefUnwindSafe,
Out: RefUnwindSafe,
St: RefUnwindSafe,

impl<St: ?Sized, FutFac, FnFac, Out> Send for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
FnFac: Send,
FutFac: Send,
St: Send,

impl<St: ?Sized, FutFac, FnFac, Out> Sync for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
FnFac: Sync,
FutFac: Sync,
Out: Sync,
St: Sync,

impl<St: ?Sized, FutFac, FnFac, Out> Unpin for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
FnFac: Unpin,
FutFac: Unpin,
Out: Unpin,
St: Unpin,

impl<St: ?Sized, FutFac, FnFac, Out> UnwindSafe for ParAsyncTailBlockBuilder<St, FutFac, FnFac, Out> where
FnFac: UnwindSafe,
FutFac: UnwindSafe,
Out: UnwindSafe,
St: UnwindSafe,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,