[−][src]Struct asparit::SequentialExecutor
Trait Implementations
impl Default for Sequential[src]
pub fn default() -> Sequential[src]
impl<'a, T1, T2, T3> Executor<'a, T1, T2, T3> for Sequential where
T1: Send + 'a,
T2: Send + 'a,
T3: Send + 'a, [src]
T1: Send + 'a,
T2: Send + 'a,
T3: Send + 'a,
type Result = T1
type Inner = Sequential
pub fn exec<P, C, R>(self, producer: P, consumer: C) -> Self::Result where
P: Producer + 'a,
C: Consumer<P::Item, Result = T1, Reducer = R> + 'a,
R: Reducer<T1> + Send + 'a, [src]
P: Producer + 'a,
C: Consumer<P::Item, Result = T1, Reducer = R> + 'a,
R: Reducer<T1> + Send + 'a,
pub fn exec_indexed<P, C, R>(self, producer: P, consumer: C) -> Self::Result where
P: IndexedProducer + 'a,
C: Consumer<P::Item, Result = T1, Reducer = R> + 'a,
R: Reducer<T1> + Send + 'a, [src]
P: IndexedProducer + 'a,
C: Consumer<P::Item, Result = T1, Reducer = R> + 'a,
R: Reducer<T1> + Send + 'a,
pub fn ready(self, value: T1) -> Self::Result[src]
pub fn split(self) -> (Self, Self)[src]
pub fn join<R>(left: T1, right: T1, reducer: R) -> Self::Result where
R: Reducer<T1> + Send, [src]
R: Reducer<T1> + Send,
pub fn into_inner(self) -> Self::Inner[src]
pub fn map<O>(
inner: <Self::Inner as Executor<'a, T2, T3, ()>>::Result,
operation: O
) -> Self::Result where
O: FnMut(T2) -> T1, [src]
inner: <Self::Inner as Executor<'a, T2, T3, ()>>::Result,
operation: O
) -> Self::Result where
O: FnMut(T2) -> T1,
Auto Trait Implementations
impl RefUnwindSafe for Sequential
impl Send for Sequential
impl Sync for Sequential
impl Unpin for Sequential
impl UnwindSafe for Sequential
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,