Trait amadeus_core::dist_sink::Factory

pub trait Factory {
    type Item;
    fn make(&self) -> Self::Item;
}

Associated Types

type Item

Loading content...

Required methods

fn make(&self) -> Self::Item

Loading content...

Implementors

impl Factory for BoolAndReduceFactory

type Item = BoolAndReducer

fn make(&self) -> Self::Item

impl Factory for BoolOrReduceFactory

type Item = BoolOrReducer

fn make(&self) -> Self::Item

impl Factory for ReduceA0Factory

type Item = ReduceA0

fn make(&self) -> Self::Item

impl Factory for ReduceC0Factory

type Item = ReduceC0

fn make(&self) -> Self::Item

impl<A> Factory for CountReduceFactory<A>

type Item = CountReducer<A>

fn make(&self) -> Self::Item

impl<A> Factory for MostFrequentReduceFactory<A> where
    A: Clone + Hash + Eq, 

type Item = MostFrequentReducer<A>

fn make(&self) -> Self::Item

impl<A> Factory for SampleUnstableReduceFactory<A>

type Item = SampleUnstableReducer<A>

fn make(&self) -> Self::Item

impl<A, B> Factory for MostDistinctReduceFactory<A, B> where
    A: Clone + Hash + Eq,
    B: Hash, 

type Item = MostDistinctReducer<A, B>

fn make(&self) -> Self::Item

impl<A, B> Factory for SumReduceFactory<A, B> where
    B: Sum<A> + Sum, 

type Item = SumReducer<A, B>

fn make(&self) -> Self::Item

impl<A, B, F> Factory for CombineReduceFactory<A, B, F> where
    Option<B>: From<A>,
    F: Combiner<B> + Clone, 

type Item = CombineReducer<A, B, F>

fn make(&self) -> Self::Item

impl<A, F> Factory for AllReduceFactory<A, F> where
    F: FnMut(A) -> bool + Clone, 

type Item = AllReducer<A, F>

fn make(&self) -> Self::Item

impl<A, F> Factory for AnyReduceFactory<A, F> where
    F: FnMut(A) -> bool + Clone, 

type Item = AnyReducer<A, F>

fn make(&self) -> Self::Item

impl<A, F> Factory for ForEachReduceFactory<A, F> where
    F: FnMut(A) + Clone, 

type Item = ForEachReducer<A, F>

fn make(&self) -> Self::Item

impl<A, ID, F, B> Factory for FoldReducerAFactory<A, ID, F, B> where
    ID: FnMut() -> B + Clone,
    F: FnMut(B, Either<A, B>) -> B + Clone, 

type Item = FoldReducerA<A, ID, F, B>

fn make(&self) -> Self::Item

impl<A, ID, F, B> Factory for FoldReducerBFactory<A, ID, F, B> where
    ID: FnMut() -> B + Clone,
    F: FnMut(B, Either<A, B>) -> B + Clone, 

type Item = FoldReducerB<A, ID, F, B>

fn make(&self) -> Self::Item

impl<R0: Factory> Factory for ReduceA1Factory<R0>

type Item = ReduceA1<R0::Item>

fn make(&self) -> Self::Item

impl<R0: Factory> Factory for ReduceC1Factory<R0>

type Item = ReduceC1<R0::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory> Factory for ReduceA2Factory<R0, R1>

type Item = ReduceA2<R0::Item, R1::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory> Factory for ReduceC2Factory<R0, R1>

type Item = ReduceC2<R0::Item, R1::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory> Factory for ReduceA3Factory<R0, R1, R2>

type Item = ReduceA3<R0::Item, R1::Item, R2::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory> Factory for ReduceC3Factory<R0, R1, R2>

type Item = ReduceC3<R0::Item, R1::Item, R2::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory> Factory for ReduceA4Factory<R0, R1, R2, R3>

type Item = ReduceA4<R0::Item, R1::Item, R2::Item, R3::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory> Factory for ReduceC4Factory<R0, R1, R2, R3>

type Item = ReduceC4<R0::Item, R1::Item, R2::Item, R3::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory> Factory for ReduceA5Factory<R0, R1, R2, R3, R4>

type Item = ReduceA5<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory> Factory for ReduceC5Factory<R0, R1, R2, R3, R4>

type Item = ReduceC5<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory> Factory for ReduceA6Factory<R0, R1, R2, R3, R4, R5>

type Item = ReduceA6<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory> Factory for ReduceC6Factory<R0, R1, R2, R3, R4, R5>

type Item = ReduceC6<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory, R6: Factory> Factory for ReduceA7Factory<R0, R1, R2, R3, R4, R5, R6>

type Item = ReduceA7<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item, R6::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory, R6: Factory> Factory for ReduceC7Factory<R0, R1, R2, R3, R4, R5, R6>

type Item = ReduceC7<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item, R6::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory, R6: Factory, R7: Factory> Factory for ReduceA8Factory<R0, R1, R2, R3, R4, R5, R6, R7>

type Item = ReduceA8<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item, R6::Item, R7::Item>

fn make(&self) -> Self::Item

impl<R0: Factory, R1: Factory, R2: Factory, R3: Factory, R4: Factory, R5: Factory, R6: Factory, R7: Factory> Factory for ReduceC8Factory<R0, R1, R2, R3, R4, R5, R6, R7>

type Item = ReduceC8<R0::Item, R1::Item, R2::Item, R3::Item, R4::Item, R5::Item, R6::Item, R7::Item>

fn make(&self) -> Self::Item

impl<RF, B> Factory for NonzeroReduceFactory<RF> where
    RF: Factory,
    RF::Item: Reducer<Output = Zeroable<B>>, 

type Item = NonzeroReducer<RF::Item>

fn make(&self) -> Self::Item

impl<RF, E> Factory for ResultReduceFactory<RF, E> where
    RF: Factory, 

type Item = ResultReducer<RF::Item, E>

fn make(&self) -> Self::Item

impl<RF: Factory> Factory for OptionReduceFactory<RF>

type Item = OptionReducer<RF::Item>

fn make(&self) -> Self::Item

impl<T: Default + Reducer> Factory for DefaultReduceFactory<T>

type Item = T

fn make(&self) -> Self::Item

Loading content...