[−][src]Trait amadeus_core::par_sink::ReducerProcessSend
Associated Types
type Output: ProcessSend + 'static
Implementors
impl ReducerProcessSend<Sum0> for ReduceA0
[src]
impl ReducerProcessSend<bool> for BoolAndReducer
[src]
impl ReducerProcessSend<bool> for BoolOrReducer
[src]
impl ReducerProcessSend<()> for ReduceC0
[src]
impl<A, C> ReducerProcessSend<A> for FolderSyncReducer<A, C> where
C: FolderSync<A>,
C::Output: ProcessSend + 'static,
[src]
C: FolderSync<A>,
C::Output: ProcessSend + 'static,
impl<A, F> ReducerProcessSend<A> for AllReducer<A, F> where
F: FnMut(A) -> bool,
[src]
F: FnMut(A) -> bool,
impl<A, F> ReducerProcessSend<A> for AnyReducer<A, F> where
F: FnMut(A) -> bool,
[src]
F: FnMut(A) -> bool,
impl<A, F> ReducerProcessSend<A> for ForEachReducer<A, F> where
F: FnMut(A) + Clone,
[src]
F: FnMut(A) + Clone,
impl<A, T: Default + Extend<A>> ReducerProcessSend<A> for PushReducer<A, T> where
T: ProcessSend + 'static,
[src]
T: ProcessSend + 'static,
type Output = T
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::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]
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,
type Output = (A::Output, B::Output, C::Output, D::Output, E::Output, F::Output, G::Output, H::Output)
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::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]
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,
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::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
E::Output: ProcessSend + 'static,
F::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
E::Output: ProcessSend + 'static,
F::Output: ProcessSend + 'static,
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::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
E::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
E::Output: ProcessSend + 'static,
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::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
D::Output: ProcessSend + 'static,
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::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
C::Output: ProcessSend + 'static,
impl<A: Reducer<S0>, B: Reducer<S1>, S0, S1> ReducerProcessSend<Sum2<S0, S1>> for ReduceA2<A, B> where
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
B::Output: ProcessSend + 'static,
impl<A: Reducer<S0>, S0> ReducerProcessSend<Sum1<S0>> for ReduceA1<A> where
A::Output: ProcessSend + 'static,
[src]
A::Output: ProcessSend + 'static,
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>
[src]
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: 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>
[src]
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: 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>
[src]
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: 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>
[src]
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: 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>
[src]
type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output, <D as ReducerProcessSend<S3>>::Output)
impl<A: ReducerProcessSend<S0>, B: ReducerProcessSend<S1>, C: ReducerProcessSend<S2>, S0, S1, S2> ReducerProcessSend<(S0, S1, S2)> for ReduceC3<A, B, C>
[src]
type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output, <C as ReducerProcessSend<S2>>::Output)
impl<A: ReducerProcessSend<S0>, B: ReducerProcessSend<S1>, S0, S1> ReducerProcessSend<(S0, S1)> for ReduceC2<A, B>
[src]
type Output = (<A as ReducerProcessSend<S0>>::Output, <B as ReducerProcessSend<S1>>::Output)
impl<A: ReducerProcessSend<S0>, S0> ReducerProcessSend<(S0,)> for ReduceC1<A>
[src]
type Output = (<A as ReducerProcessSend<S0>>::Output,)
impl<A: IntoIterator<Item = B>, T: Default + Extend<B>, B> ReducerProcessSend<A> for ExtendReducer<A, T> where
T: ProcessSend + 'static,
[src]
T: 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::Item> + Clone,
T: Eq + Hash + ProcessSend + 'static,
R::Output: ProcessSend + 'static,
[src]
P: PipeTask<U>,
R: Reducer<P::Item> + Clone,
T: Eq + Hash + ProcessSend + 'static,
R::Output: ProcessSend + 'static,
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::Output: ProcessSend + 'static,
[src]
R: Reducer<U> + Clone,
T: Eq + Hash + ProcessSend + 'static,
R::Output: ProcessSend + 'static,
impl<R: Reducer<Item>, E, Item> ReducerProcessSend<Result<Item, E>> for ResultReducer<R, E> where
R::Output: ProcessSend + 'static,
E: ProcessSend + 'static,
[src]
R::Output: ProcessSend + 'static,
E: ProcessSend + 'static,
impl<R: Reducer<Item>, Item> ReducerProcessSend<Option<Item>> for OptionReducer<R> where
R::Output: ProcessSend + 'static,
[src]
R::Output: ProcessSend + 'static,