Trait amadeus_core::dist_sink::ReducerSend

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

Associated Types

type Output: Send + 'static

Loading content...

Implementors

impl ReducerSend for BoolAndReducer

type Output = bool

impl ReducerSend for BoolOrReducer

type Output = bool

impl ReducerSend for ReduceA0

type Output = ()

impl ReducerSend for ReduceC0

type Output = ()

impl<A> ReducerSend for CountReducer<A> where
    A: 'static, 

type Output = usize

impl<A> ReducerSend for MostFrequentReducer<A> where
    A: Clone + Hash + Eq + Send + 'static, 

type Output = Top<A, usize>

impl<A> ReducerSend for SampleUnstableReducer<A> where
    A: Send + 'static, 

type Output = SASampleUnstable<A>

impl<A, B> ReducerSend for MostDistinctReducer<A, B> where
    A: Clone + Hash + Eq + Send + 'static,
    B: Hash + 'static, 

type Output = Top<A, HyperLogLogMagnitude<B>>

impl<A, B> ReducerSend for SumReducer<A, B> where
    A: 'static,
    B: Sum<A> + Sum + Send + 'static, 

type Output = B

impl<A, B, F> ReducerSend for CombineReducer<A, B, F> where
    A: 'static,
    Option<B>: From<A>,
    F: Combiner<B> + Send + 'static,
    B: Send + 'static, 

type Output = Option<B>

impl<A, F> ReducerSend for AllReducer<A, F> where
    A: 'static,
    F: FnMut(A) -> bool + Send + 'static, 

type Output = bool

impl<A, F> ReducerSend for AnyReducer<A, F> where
    A: 'static,
    F: FnMut(A) -> bool + Send + 'static, 

type Output = bool

impl<A, F> ReducerSend for ForEachReducer<A, F> where
    A: 'static,
    F: FnMut(A) + Clone + Send + 'static, 

type Output = ()

impl<A, ID, F, B> ReducerSend for FoldReducerA<A, ID, F, B> where
    A: 'static,
    ID: FnMut() -> B + Clone + Send + 'static,
    F: FnMut(B, Either<A, B>) -> B + Clone + Send + 'static,
    B: Send + 'static, 

type Output = B

impl<A, ID, F, B> ReducerSend for FoldReducerB<A, ID, F, B> where
    A: 'static,
    ID: FnMut() -> B + Clone + Send + 'static,
    F: FnMut(B, Either<A, B>) -> B + Clone + Send + 'static,
    B: Send + 'static, 

type Output = B

impl<A, T: Push<A>> ReducerSend for PushReducer<A, T> where
    A: 'static,
    T: Send + 'static, 

type Output = T

impl<A: Reducer> ReducerSend for ReduceA1<A> where
    A: Send + 'static,
    A::Output: Send + 'static, 

type Output = (A::Output,)

impl<A: Reducer, B: Reducer> ReducerSend for ReduceA2<A, B> where
    A: Send + 'static,
    B: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static, 

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

impl<A: Reducer, B: Reducer, C: Reducer> ReducerSend for ReduceA3<A, B, C> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static, 

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

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer> ReducerSend for ReduceA4<A, B, C, D> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    D: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static,
    D::Output: Send + 'static, 

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

impl<A: Reducer, B: Reducer, C: Reducer, D: Reducer, E: Reducer> ReducerSend for ReduceA5<A, B, C, D, E> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    D: Send + 'static,
    E: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static,
    D::Output: Send + 'static,
    E::Output: Send + 'static, 

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> ReducerSend for ReduceA6<A, B, C, D, E, F> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    D: Send + 'static,
    E: Send + 'static,
    F: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static,
    D::Output: Send + 'static,
    E::Output: Send + 'static,
    F::Output: Send + 'static, 

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> ReducerSend for ReduceA7<A, B, C, D, E, F, G> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    D: Send + 'static,
    E: Send + 'static,
    F: Send + 'static,
    G: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static,
    D::Output: Send + 'static,
    E::Output: Send + 'static,
    F::Output: Send + 'static,
    G::Output: Send + 'static, 

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> ReducerSend for ReduceA8<A, B, C, D, E, F, G, H> where
    A: Send + 'static,
    B: Send + 'static,
    C: Send + 'static,
    D: Send + 'static,
    E: Send + 'static,
    F: Send + 'static,
    G: Send + 'static,
    H: Send + 'static,
    A::Output: Send + 'static,
    B::Output: Send + 'static,
    C::Output: Send + 'static,
    D::Output: Send + 'static,
    E::Output: Send + 'static,
    F::Output: Send + 'static,
    G::Output: Send + 'static,
    H::Output: Send + 'static, 

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

impl<A: ReducerSend> ReducerSend for ReduceC1<A>

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

impl<A: ReducerSend, B: ReducerSend> ReducerSend for ReduceC2<A, B>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend> ReducerSend for ReduceC3<A, B, C>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend, D: ReducerSend> ReducerSend for ReduceC4<A, B, C, D>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend, D: ReducerSend, E: ReducerSend> ReducerSend for ReduceC5<A, B, C, D, E>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend, D: ReducerSend, E: ReducerSend, F: ReducerSend> ReducerSend for ReduceC6<A, B, C, D, E, F>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend, D: ReducerSend, E: ReducerSend, F: ReducerSend, G: ReducerSend> ReducerSend for ReduceC7<A, B, C, D, E, F, G>

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

impl<A: ReducerSend, B: ReducerSend, C: ReducerSend, D: ReducerSend, E: ReducerSend, F: ReducerSend, G: ReducerSend, H: ReducerSend> ReducerSend for ReduceC8<A, B, C, D, E, F, G, H>

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

impl<A: IntoIterator<Item = B>, T: Extend<B>, B> ReducerSend for ExtendReducer<A, T> where
    A: 'static,
    T: Send + 'static, 

type Output = T

impl<R, B> ReducerSend for NonzeroReducer<R> where
    R: Reducer<Output = Zeroable<B>> + Send + 'static,
    B: Send + 'static, 

type Output = B

impl<R: Reducer> ReducerSend for OptionReducer<R> where
    R: Send + 'static,
    R::Output: Send + 'static, 

type Output = Option<R::Output>

impl<R: Reducer, E> ReducerSend for ResultReducer<R, E> where
    R: Send + 'static,
    R::Output: Send + 'static,
    E: Send + 'static, 

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

Loading content...