Trait ReducerProcessSend 

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

Required Associated Types

type Done: ProcessSend + 'static

Implementors

impl ReducerProcessSend<Sum0> for ReduceA0

type Done = ()

impl ReducerProcessSend<bool> for BoolAndReducer

type Done = bool

impl ReducerProcessSend<bool> for BoolOrReducer

type Done = bool

impl ReducerProcessSend<()> for ReduceC0

type Done = ()

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, F: Reducer<S5>, G: Reducer<S6>, H: Reducer<S7>, 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::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static, D::Done: ProcessSend + 'static, E::Done: ProcessSend + 'static, F::Done: ProcessSend + 'static, G::Done: ProcessSend + 'static, H::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, F: Reducer<S5>, G: Reducer<S6>, 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::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static, D::Done: ProcessSend + 'static, E::Done: ProcessSend + 'static, F::Done: ProcessSend + 'static, G::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, F: Reducer<S5>, S0, S1, S2, S3, S4, S5> ReducerProcessSend<Sum6<S0, S1, S2, S3, S4, S5>> for ReduceA6<A, B, C, D, E, F>

where A::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static, D::Done: ProcessSend + 'static, E::Done: ProcessSend + 'static, F::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, S0, S1, S2, S3, S4> ReducerProcessSend<Sum5<S0, S1, S2, S3, S4>> for ReduceA5<A, B, C, D, E>

where A::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static, D::Done: ProcessSend + 'static, E::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, S0, S1, S2, S3> ReducerProcessSend<Sum4<S0, S1, S2, S3>> for ReduceA4<A, B, C, D>

where A::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static, D::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> ReducerProcessSend<Sum3<S0, S1, S2>> for ReduceA3<A, B, C>

where A::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static, C::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, B: Reducer<S1>, S0, S1> ReducerProcessSend<Sum2<S0, S1>> for ReduceA2<A, B>

where A::Done: ProcessSend + 'static, B::Done: ProcessSend + 'static,

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

impl<A: Reducer<S0>, S0> ReducerProcessSend<Sum1<S0>> for ReduceA1<A>

where A::Done: ProcessSend + 'static,

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

impl<A: ReducerProcessSend<S0>, B: ReducerProcessSend<S1>, C: ReducerProcessSend<S2>, D: ReducerProcessSend<S3>, E: ReducerProcessSend<S4>, F: ReducerProcessSend<S5>, G: ReducerProcessSend<S6>, H: ReducerProcessSend<S7>, 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>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<Item, F> ReducerProcessSend<Item> for AllReducer<Item, F>

where F: FnMut<(Item,), Output = bool>,

type Done = bool

impl<Item, F> ReducerProcessSend<Item> for AnyReducer<Item, F>

where F: FnMut<(Item,), Output = bool>,

type Done = bool

impl<Item, F> ReducerProcessSend<Item> for FolderSyncReducer<Item, F, Final>

where F: FolderSync<Item>, F::Done: ProcessSend + 'static,

type Done = <F as FolderSync<Item>>::Done

impl<Item, F> ReducerProcessSend<Item> for FolderSyncReducer<Item, F, Inter>

where F: FolderSync<Item>, F::State: ProcessSend + 'static,

type Done = <F as FolderSync<Item>>::State

impl<Item, F> ReducerProcessSend<Item> for ForEachReducer<Item, F>

where F: FnMut<(Item,), Output = ()>,

type Done = ()

impl<Item, T> ReducerProcessSend<Item> for PushReducer<Item, T>

where T: ProcessSend + 'static + Default + Extend<Item>,

type Done = T

impl<Item: IntoIterator<Item = B>, T, B> ReducerProcessSend<Item> for ExtendReducer<Item, T>

where T: ProcessSend + 'static + Default + Extend<B>,

type Done = T

impl<P, R, T, U> ReducerProcessSend<(T, U)> for GroupByReducerA<P, R, T, U>

where P: PipeTask<U>, R: Reducer<P::Output> + Clone, T: Eq + Hash + ProcessSend + 'static, R::Done: ProcessSend + 'static,

type Done = IndexMap<T, <R as Reducer<<P as PipeTask<U>>::Output>>::Done>

impl<R, T, U> ReducerProcessSend<IndexMap<T, U>> for GroupByReducerB<R, T, U>

where R: Reducer<U> + Clone, T: Eq + Hash + ProcessSend + 'static, R::Done: ProcessSend + 'static,

type Done = IndexMap<T, <R as Reducer<U>>::Done>

impl<R: Reducer<Item>, E, Item> ReducerProcessSend<Result<Item, E>> for ResultReducer<R, E>

where R::Done: ProcessSend + 'static, E: ProcessSend + 'static,

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

impl<R: Reducer<Item>, Item> ReducerProcessSend<Option<Item>> for OptionReducer<R>

where R::Done: ProcessSend + 'static,

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