[−][src]Trait amadeus_core::par_sink::ReducerProcessSend

pub trait ReducerProcessSend: ReducerSend<Output = Self::Output> {
    type Output: ProcessSend + 'static;
}

Associated Types

type Output: ProcessSend + 'static

Loading content...

Implementors

impl ReducerProcessSend for BoolAndReducer[src]

type Output = bool

impl ReducerProcessSend for BoolOrReducer[src]

type Output = bool

impl ReducerProcessSend for ReduceA0[src]

type Output = ()

impl ReducerProcessSend for ReduceC0[src]

type Output = ()

impl<A, C> ReducerProcessSend for FolderSyncReducer<A, C> where
    C: FolderSync<A>,
    C::Output: ProcessSend + 'static, [src]

type Output = C::Output

impl<A, F> ReducerProcessSend for AllReducer<A, F> where
    F: FnMut(A) -> bool, [src]

type Output = bool

impl<A, F> ReducerProcessSend for AnyReducer<A, F> where
    F: FnMut(A) -> bool, [src]

type Output = bool

impl<A, F> ReducerProcessSend for ForEachReducer<A, F> where
    F: FnMut(A) + Clone, [src]

type Output = ()

impl<A, T: Extend<A>> ReducerProcessSend for PushReducer<A, T> where
    T: ProcessSend + 'static, [src]

type Output = T

impl<A: Reducer> ReducerProcessSend for ReduceA1<A> where
    A::Output: ProcessSend + 'static, [src]

type Output = (A::Output,)

impl<A: Reducer, B: Reducer> ReducerProcessSend for ReduceA2<A, B> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output)

impl<A: Reducer, B: Reducer, C: Reducer> ReducerProcessSend for ReduceA3<A, B, C> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output)

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer> ReducerProcessSend for ReduceA4<A, B, C, D> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static,
    D::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output, D::Output)

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer> ReducerProcessSend for ReduceA5<A, B, C, D, E> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static,
    D::Output: ProcessSend + 'static,
    E::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output, D::Output, E::Output)

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer, F: Reducer> ReducerProcessSend for ReduceA6<A, B, C, D, E, F> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static,
    D::Output: ProcessSend + 'static,
    E::Output: ProcessSend + 'static,
    F::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output, D::Output, E::Output, F::Output)

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer, F: Reducer, G: Reducer> ReducerProcessSend for ReduceA7<A, B, C, D, E, F, G> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static,
    D::Output: ProcessSend + 'static,
    E::Output: ProcessSend + 'static,
    F::Output: ProcessSend + 'static,
    G::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output, D::Output, E::Output, F::Output, G::Output)

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer, F: Reducer, G: Reducer, H: Reducer> ReducerProcessSend for ReduceA8<A, B, C, D, E, F, G, H> where
    A::Output: ProcessSend + 'static,
    B::Output: ProcessSend + 'static,
    C::Output: ProcessSend + 'static,
    D::Output: ProcessSend + 'static,
    E::Output: ProcessSend + 'static,
    F::Output: ProcessSend + 'static,
    G::Output: ProcessSend + 'static,
    H::Output: ProcessSend + 'static, [src]

type Output = (A::Output, B::Output, C::Output, D::Output, E::Output, F::Output, G::Output, H::Output)

impl<A: ReducerProcessSend> ReducerProcessSend for ReduceC1<A>[src]

type Output = (<A as ReducerProcessSend>::Output,)

impl<A: ReducerProcessSend, B: ReducerProcessSend> ReducerProcessSend for ReduceC2<A, B>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend> ReducerProcessSend for ReduceC3<A, B, C>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend, D: ReducerProcessSend> ReducerProcessSend for ReduceC4<A, B, C, D>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output, <D as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend, D: ReducerProcessSend, E: ReducerProcessSend> ReducerProcessSend for ReduceC5<A, B, C, D, E>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output, <D as ReducerProcessSend>::Output, <E as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend, D: ReducerProcessSend, E: ReducerProcessSend, F: ReducerProcessSend> ReducerProcessSend for ReduceC6<A, B, C, D, E, F>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output, <D as ReducerProcessSend>::Output, <E as ReducerProcessSend>::Output, <F as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend, D: ReducerProcessSend, E: ReducerProcessSend, F: ReducerProcessSend, G: ReducerProcessSend> ReducerProcessSend for ReduceC7<A, B, C, D, E, F, G>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output, <D as ReducerProcessSend>::Output, <E as ReducerProcessSend>::Output, <F as ReducerProcessSend>::Output, <G as ReducerProcessSend>::Output)

impl<A: ReducerProcessSend, B: ReducerProcessSend, C: ReducerProcessSend, D: ReducerProcessSend, E: ReducerProcessSend, F: ReducerProcessSend, G: ReducerProcessSend, H: ReducerProcessSend> ReducerProcessSend for ReduceC8<A, B, C, D, E, F, G, H>[src]

type Output = (<A as ReducerProcessSend>::Output, <B as ReducerProcessSend>::Output, <C as ReducerProcessSend>::Output, <D as ReducerProcessSend>::Output, <E as ReducerProcessSend>::Output, <F as ReducerProcessSend>::Output, <G as ReducerProcessSend>::Output, <H as ReducerProcessSend>::Output)

impl<A: IntoIterator<Item = B>, T: Extend<B>, B> ReducerProcessSend for ExtendReducer<A, T> where
    T: ProcessSend + 'static, [src]

type Output = T

impl<R: Reducer> ReducerProcessSend for OptionReducer<R> where
    R::Output: ProcessSend + 'static, [src]

type Output = Option<R::Output>

impl<R: Reducer, E> ReducerProcessSend for ResultReducer<R, E> where
    R::Output: ProcessSend + 'static,
    E: ProcessSend + 'static, [src]

type Output = Result<R::Output, E>

Loading content...