Trait amadeus::par_sink::ReducerProcessSend

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

Associated Types

type Output: 'static + ProcessSend

Loading content...

Implementors

impl ReducerProcessSend<Sum0> for ReduceA0

type Output = ()

impl ReducerProcessSend<bool> for BoolAndReducer

type Output = bool

impl ReducerProcessSend<bool> for BoolOrReducer

type Output = bool

impl ReducerProcessSend<()> for ReduceC0

type Output = ()

impl<A, B, C, D, E, F, G, H, S0, S1, S2, S3, S4, S5, S6, S7> ReducerProcessSend<Sum8<S0, S1, S2, S3, S4, S5, S6, S7>> for ReduceA8<A, B, C, D, E, F, G, H> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    D: Reducer<S3>,
    E: Reducer<S4>,
    F: Reducer<S5>,
    G: Reducer<S6>,
    H: Reducer<S7>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static,
    <D as Reducer<S3>>::Output: ProcessSend,
    <D as Reducer<S3>>::Output: 'static,
    <E as Reducer<S4>>::Output: ProcessSend,
    <E as Reducer<S4>>::Output: 'static,
    <F as Reducer<S5>>::Output: ProcessSend,
    <F as Reducer<S5>>::Output: 'static,
    <G as Reducer<S6>>::Output: ProcessSend,
    <G as Reducer<S6>>::Output: 'static,
    <H as Reducer<S7>>::Output: ProcessSend,
    <H as Reducer<S7>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output, <D as Reducer<S3>>::Output, <E as Reducer<S4>>::Output, <F as Reducer<S5>>::Output, <G as Reducer<S6>>::Output, <H as Reducer<S7>>::Output)

impl<A, B, C, D, E, F, G, H, S0, S1, S2, S3, S4, S5, S6, S7> ReducerProcessSend<(S0, S1, S2, S3, S4, S5, S6, S7)> for ReduceC8<A, B, C, D, E, F, G, H> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>,
    D: ReducerProcessSend<S3>,
    E: ReducerProcessSend<S4>,
    F: ReducerProcessSend<S5>,
    G: ReducerProcessSend<S6>,
    H: ReducerProcessSend<S7>, 

type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output, <E as ReducerProcessSend<S4>>::Output, <F as ReducerProcessSend<S5>>::Output, <G as ReducerProcessSend<S6>>::Output, <H as ReducerProcessSend<S7>>::Output)

impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> ReducerProcessSend<Sum7<S0, S1, S2, S3, S4, S5, S6>> for ReduceA7<A, B, C, D, E, F, G> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    D: Reducer<S3>,
    E: Reducer<S4>,
    F: Reducer<S5>,
    G: Reducer<S6>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static,
    <D as Reducer<S3>>::Output: ProcessSend,
    <D as Reducer<S3>>::Output: 'static,
    <E as Reducer<S4>>::Output: ProcessSend,
    <E as Reducer<S4>>::Output: 'static,
    <F as Reducer<S5>>::Output: ProcessSend,
    <F as Reducer<S5>>::Output: 'static,
    <G as Reducer<S6>>::Output: ProcessSend,
    <G as Reducer<S6>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output, <D as Reducer<S3>>::Output, <E as Reducer<S4>>::Output, <F as Reducer<S5>>::Output, <G as Reducer<S6>>::Output)

impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> ReducerProcessSend<(S0, S1, S2, S3, S4, S5, S6)> for ReduceC7<A, B, C, D, E, F, G> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>,
    D: ReducerProcessSend<S3>,
    E: ReducerProcessSend<S4>,
    F: ReducerProcessSend<S5>,
    G: ReducerProcessSend<S6>, 

type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output, <E as ReducerProcessSend<S4>>::Output, <F as ReducerProcessSend<S5>>::Output, <G as ReducerProcessSend<S6>>::Output)

impl<A, B, C, D, E, F, S0, S1, S2, S3, S4, S5> ReducerProcessSend<Sum6<S0, S1, S2, S3, S4, S5>> for ReduceA6<A, B, C, D, E, F> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    D: Reducer<S3>,
    E: Reducer<S4>,
    F: Reducer<S5>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static,
    <D as Reducer<S3>>::Output: ProcessSend,
    <D as Reducer<S3>>::Output: 'static,
    <E as Reducer<S4>>::Output: ProcessSend,
    <E as Reducer<S4>>::Output: 'static,
    <F as Reducer<S5>>::Output: ProcessSend,
    <F as Reducer<S5>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output, <D as Reducer<S3>>::Output, <E as Reducer<S4>>::Output, <F as Reducer<S5>>::Output)

impl<A, B, C, D, E, F, S0, S1, S2, S3, S4, S5> ReducerProcessSend<(S0, S1, S2, S3, S4, S5)> for ReduceC6<A, B, C, D, E, F> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>,
    D: ReducerProcessSend<S3>,
    E: ReducerProcessSend<S4>,
    F: ReducerProcessSend<S5>, 

type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output, <E as ReducerProcessSend<S4>>::Output, <F as ReducerProcessSend<S5>>::Output)

impl<A, B, C, D, E, S0, S1, S2, S3, S4> ReducerProcessSend<Sum5<S0, S1, S2, S3, S4>> for ReduceA5<A, B, C, D, E> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    D: Reducer<S3>,
    E: Reducer<S4>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static,
    <D as Reducer<S3>>::Output: ProcessSend,
    <D as Reducer<S3>>::Output: 'static,
    <E as Reducer<S4>>::Output: ProcessSend,
    <E as Reducer<S4>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output, <D as Reducer<S3>>::Output, <E as Reducer<S4>>::Output)

impl<A, B, C, D, E, S0, S1, S2, S3, S4> ReducerProcessSend<(S0, S1, S2, S3, S4)> for ReduceC5<A, B, C, D, E> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>,
    D: ReducerProcessSend<S3>,
    E: ReducerProcessSend<S4>, 

type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output, <E as ReducerProcessSend<S4>>::Output)

impl<A, B, C, D, S0, S1, S2, S3> ReducerProcessSend<Sum4<S0, S1, S2, S3>> for ReduceA4<A, B, C, D> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    D: Reducer<S3>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static,
    <D as Reducer<S3>>::Output: ProcessSend,
    <D as Reducer<S3>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output, <D as Reducer<S3>>::Output)

impl<A, B, C, D, S0, S1, S2, S3> ReducerProcessSend<(S0, S1, S2, S3)> for ReduceC4<A, B, C, D> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>,
    D: ReducerProcessSend<S3>, 

type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output)

impl<A, B, C, S0, S1, S2> ReducerProcessSend<Sum3<S0, S1, S2>> for ReduceA3<A, B, C> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    C: Reducer<S2>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static,
    <C as Reducer<S2>>::Output: ProcessSend,
    <C as Reducer<S2>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output, <C as Reducer<S2>>::Output)

impl<A, B, C, S0, S1, S2> ReducerProcessSend<(S0, S1, S2)> for ReduceC3<A, B, C> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>,
    C: ReducerProcessSend<S2>, 

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

impl<A, B, S0, S1> ReducerProcessSend<Sum2<S0, S1>> for ReduceA2<A, B> where
    A: Reducer<S0>,
    B: Reducer<S1>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static,
    <B as Reducer<S1>>::Output: ProcessSend,
    <B as Reducer<S1>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output, <B as Reducer<S1>>::Output)

impl<A, B, S0, S1> ReducerProcessSend<(S0, S1)> for ReduceC2<A, B> where
    A: ReducerProcessSend<S0>,
    B: ReducerProcessSend<S1>, 

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

impl<A, C> ReducerProcessSend<A> for FolderSyncReducer<A, C> where
    C: FolderSync<A>,
    <C as FolderSync<A>>::Output: ProcessSend,
    <C as FolderSync<A>>::Output: 'static, 

type Output = <C as FolderSync<A>>::Output

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

type Output = bool

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

type Output = bool

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

type Output = ()

impl<A, S0> ReducerProcessSend<Sum1<S0>> for ReduceA1<A> where
    A: Reducer<S0>,
    <A as Reducer<S0>>::Output: ProcessSend,
    <A as Reducer<S0>>::Output: 'static, 

type Output = (<A as Reducer<S0>>::Output,)

impl<A, S0> ReducerProcessSend<(S0,)> for ReduceC1<A> where
    A: ReducerProcessSend<S0>, 

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

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

type Output = T

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

type Output = T

impl<P, R, T, U> ReducerProcessSend<(T, U)> for GroupByReducerA<P, R, T, U> where
    P: PipeTask<U>,
    R: Reducer<<P as PipeTask<U>>::Item> + Clone,
    T: Eq + Hash + ProcessSend + 'static,
    <R as Reducer<<P as PipeTask<U>>::Item>>::Output: ProcessSend,
    <R as Reducer<<P as PipeTask<U>>::Item>>::Output: 'static, 

type Output = HashMap<T, <R as Reducer<<P as PipeTask<U>>::Item>>::Output, RandomState>

impl<R, E, Item> ReducerProcessSend<Result<Item, E>> for ResultReducer<R, E> where
    E: ProcessSend + 'static,
    R: Reducer<Item>,
    <R as Reducer<Item>>::Output: ProcessSend,
    <R as Reducer<Item>>::Output: 'static, 

type Output = Result<<R as Reducer<Item>>::Output, E>

impl<R, Item> ReducerProcessSend<Option<Item>> for OptionReducer<R> where
    R: Reducer<Item>,
    <R as Reducer<Item>>::Output: ProcessSend,
    <R as Reducer<Item>>::Output: 'static, 

type Output = Option<<R as Reducer<Item>>::Output>

impl<R, T, U> ReducerProcessSend<HashMap<T, U, RandomState>> for GroupByReducerB<R, T, U> where
    R: Reducer<U> + Clone,
    T: Eq + Hash + ProcessSend + 'static,
    <R as Reducer<U>>::Output: ProcessSend,
    <R as Reducer<U>>::Output: 'static, 

type Output = HashMap<T, <R as Reducer<U>>::Output, RandomState>

Loading content...