Trait amadeus_core::par_sink::ReducerSend

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

Associated Types

type Done: Send + 'static

Loading content...

Implementors

impl ReducerSend<Sum0> for ReduceA0

type Done = ()

impl ReducerSend<bool> for BoolAndReducer

type Done = bool

impl ReducerSend<bool> for BoolOrReducer

type Done = bool

impl ReducerSend<()> 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> ReducerSend<Sum8<S0, S1, S2, S3, S4, S5, S6, S7>> for ReduceA8<A, B, C, D, E, F, G, H> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static,
    D::Done: Send + 'static,
    E::Done: Send + 'static,
    F::Done: Send + 'static,
    G::Done: Send + 'static,
    H::Done: Send + 'static, 

type Done = (A::Done, B::Done, C::Done, D::Done, E::Done, F::Done, G::Done, H::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> ReducerSend<Sum7<S0, S1, S2, S3, S4, S5, S6>> for ReduceA7<A, B, C, D, E, F, G> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static,
    D::Done: Send + 'static,
    E::Done: Send + 'static,
    F::Done: Send + 'static,
    G::Done: Send + 'static, 

type Done = (A::Done, B::Done, C::Done, D::Done, E::Done, F::Done, G::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> ReducerSend<Sum6<S0, S1, S2, S3, S4, S5>> for ReduceA6<A, B, C, D, E, F> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static,
    D::Done: Send + 'static,
    E::Done: Send + 'static,
    F::Done: Send + 'static, 

type Done = (A::Done, B::Done, C::Done, D::Done, E::Done, F::Done)

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, S0, S1, S2, S3, S4> ReducerSend<Sum5<S0, S1, S2, S3, S4>> for ReduceA5<A, B, C, D, E> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static,
    D::Done: Send + 'static,
    E::Done: Send + 'static, 

type Done = (A::Done, B::Done, C::Done, D::Done, E::Done)

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, S0, S1, S2, S3> ReducerSend<Sum4<S0, S1, S2, S3>> for ReduceA4<A, B, C, D> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static,
    D::Done: Send + 'static, 

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

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> ReducerSend<Sum3<S0, S1, S2>> for ReduceA3<A, B, C> where
    A::Done: Send + 'static,
    B::Done: Send + 'static,
    C::Done: Send + 'static, 

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

impl<A: Reducer<S0>, B: Reducer<S1>, S0, S1> ReducerSend<Sum2<S0, S1>> for ReduceA2<A, B> where
    A::Done: Send + 'static,
    B::Done: Send + 'static, 

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

impl<A: Reducer<S0>, S0> ReducerSend<Sum1<S0>> for ReduceA1<A> where
    A::Done: Send + 'static, 

type Done = (A::Done,)

impl<A: ReducerSend<S0>, B: ReducerSend<S1>, C: ReducerSend<S2>, D: ReducerSend<S3>, E: ReducerSend<S4>, F: ReducerSend<S5>, G: ReducerSend<S6>, H: ReducerSend<S7>, S0, S1, S2, S3, S4, S5, S6, S7> ReducerSend<(S0, S1, S2, S3, S4, S5, S6, S7)> for ReduceC8<A, B, C, D, E, F, G, H>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<Item, F> ReducerSend<Item> for AllReducer<Item, F> where
    F: FnMut<(Item,), Output = bool>, 

type Done = bool

impl<Item, F> ReducerSend<Item> for AnyReducer<Item, F> where
    F: FnMut<(Item,), Output = bool>, 

type Done = bool

impl<Item, F> ReducerSend<Item> for FolderSyncReducer<Item, F> where
    F: FolderSync<Item>,
    F::Done: Send + 'static, 

type Done = F::Done

impl<Item, F> ReducerSend<Item> for ForEachReducer<Item, F> where
    F: FnMut<(Item,), Output = ()>, 

type Done = ()

impl<Item, T: Default + Extend<Item>> ReducerSend<Item> for PushReducer<Item, T> where
    T: Send + 'static, 

type Done = T

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

type Done = T

impl<P, R, T, U> ReducerSend<(T, U)> for GroupByReducerA<P, R, T, U> where
    P: PipeTask<U>,
    R: Reducer<P::Output> + Clone,
    T: Eq + Hash + Send + 'static,
    R::Done: Send + 'static, 

type Done = IndexMap<T, R::Done>

impl<R, T, U> ReducerSend<IndexMap<T, U, RandomState>> for GroupByReducerB<R, T, U> where
    R: Reducer<U> + Clone,
    T: Eq + Hash + Send + 'static,
    R::Done: Send + 'static, 

type Done = IndexMap<T, R::Done>

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

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

impl<R: Reducer<Item>, Item> ReducerSend<Option<Item>> for OptionReducer<R> where
    R::Done: Send + 'static, 

type Done = Option<R::Done>

Loading content...