[−][src]Trait amadeus_core::dist_sink::ReducerProcessSend
Associated Types
type Output: ProcessSend
Implementors
impl ReducerProcessSend for BoolAndReducer
[src]
impl ReducerProcessSend for BoolOrReducer
[src]
impl ReducerProcessSend for ReduceA0
[src]
impl ReducerProcessSend for ReduceC0
[src]
impl<A> ReducerProcessSend for CountReducer<A> where
A: 'static,
[src]
A: 'static,
impl<A> ReducerProcessSend for MostFrequentReducer<A> where
A: Clone + Hash + Eq + ProcessSend,
[src]
A: Clone + Hash + Eq + ProcessSend,
impl<A> ReducerProcessSend for SampleUnstableReducer<A> where
A: ProcessSend,
[src]
A: ProcessSend,
type Output = SASampleUnstable<A>
impl<A, B> ReducerProcessSend for MostDistinctReducer<A, B> where
A: Clone + Hash + Eq + ProcessSend,
B: Hash + 'static,
[src]
A: Clone + Hash + Eq + ProcessSend,
B: Hash + 'static,
type Output = Top<A, HyperLogLogMagnitude<B>>
impl<A, B> ReducerProcessSend for SumReducer<A, B> where
A: 'static,
B: Sum<A> + Sum + ProcessSend,
[src]
A: 'static,
B: Sum<A> + Sum + ProcessSend,
type Output = B
impl<A, B, F> ReducerProcessSend for CombineReducer<A, B, F> where
A: 'static,
Option<B>: From<A>,
F: Combiner<B> + ProcessSend,
B: ProcessSend,
[src]
A: 'static,
Option<B>: From<A>,
F: Combiner<B> + ProcessSend,
B: ProcessSend,
impl<A, F> ReducerProcessSend for AllReducer<A, F> where
A: 'static,
F: FnMut(A) -> bool + ProcessSend,
[src]
A: 'static,
F: FnMut(A) -> bool + ProcessSend,
impl<A, F> ReducerProcessSend for AnyReducer<A, F> where
A: 'static,
F: FnMut(A) -> bool + ProcessSend,
[src]
A: 'static,
F: FnMut(A) -> bool + ProcessSend,
impl<A, F> ReducerProcessSend for ForEachReducer<A, F> where
A: 'static,
F: FnMut(A) + Clone + ProcessSend,
[src]
A: 'static,
F: FnMut(A) + Clone + ProcessSend,
impl<A, ID, F, B> ReducerProcessSend for FoldReducerA<A, ID, F, B> where
A: 'static,
ID: FnMut() -> B + Clone + ProcessSend,
F: FnMut(B, Either<A, B>) -> B + Clone + ProcessSend,
B: ProcessSend,
[src]
A: 'static,
ID: FnMut() -> B + Clone + ProcessSend,
F: FnMut(B, Either<A, B>) -> B + Clone + ProcessSend,
B: ProcessSend,
type Output = B
impl<A, ID, F, B> ReducerProcessSend for FoldReducerB<A, ID, F, B> where
A: 'static,
ID: FnMut() -> B + Clone + ProcessSend,
F: FnMut(B, Either<A, B>) -> B + Clone + ProcessSend,
B: ProcessSend,
[src]
A: 'static,
ID: FnMut() -> B + Clone + ProcessSend,
F: FnMut(B, Either<A, B>) -> B + Clone + ProcessSend,
B: ProcessSend,
type Output = B
impl<A, T: Push<A>> ReducerProcessSend for PushReducer<A, T> where
A: 'static,
T: ProcessSend,
[src]
A: 'static,
T: ProcessSend,
type Output = T
impl<A: Reducer> ReducerProcessSend for ReduceA1<A> where
A: ProcessSend,
A::Output: ProcessSend,
[src]
A: ProcessSend,
A::Output: ProcessSend,
impl<A: Reducer, B: Reducer> ReducerProcessSend for ReduceA2<A, B> where
A: ProcessSend,
B: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
impl<A: Reducer, B: Reducer, C: Reducer> ReducerProcessSend for ReduceA3<A, B, C> where
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer> ReducerProcessSend for ReduceA4<A, B, C, D> where
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer> ReducerProcessSend for ReduceA5<A, B, C, D, E> where
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer, F: Reducer> ReducerProcessSend for ReduceA6<A, B, C, D, E, F> where
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
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: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
G: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
G::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
G: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
G::Output: ProcessSend,
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: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
G: ProcessSend,
H: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
G::Output: ProcessSend,
H::Output: ProcessSend,
[src]
A: ProcessSend,
B: ProcessSend,
C: ProcessSend,
D: ProcessSend,
E: ProcessSend,
F: ProcessSend,
G: ProcessSend,
H: ProcessSend,
A::Output: ProcessSend,
B::Output: ProcessSend,
C::Output: ProcessSend,
D::Output: ProcessSend,
E::Output: ProcessSend,
F::Output: ProcessSend,
G::Output: ProcessSend,
H::Output: ProcessSend,
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
A: 'static,
T: ProcessSend,
[src]
A: 'static,
T: ProcessSend,
type Output = T
impl<R, B> ReducerProcessSend for NonzeroReducer<R> where
R: Reducer<Output = Zeroable<B>> + ProcessSend,
B: ProcessSend,
[src]
R: Reducer<Output = Zeroable<B>> + ProcessSend,
B: ProcessSend,
type Output = B
impl<R: Reducer> ReducerProcessSend for OptionReducer<R> where
R: ProcessSend,
R::Output: ProcessSend,
[src]
R: ProcessSend,
R::Output: ProcessSend,
impl<R: Reducer, E> ReducerProcessSend for ResultReducer<R, E> where
R: ProcessSend,
R::Output: ProcessSend,
E: ProcessSend,
[src]
R: ProcessSend,
R::Output: ProcessSend,
E: ProcessSend,