Trait amadeus_core::par_sink::Reducer

#[must_use]pub trait Reducer<Source> {
    type Output;
    type Async: ReducerAsync<Source, Output = Self::Output>;
    fn into_async(self) -> Self::Async;
}

Associated Types

type Output

type Async: ReducerAsync<Source, Output = Self::Output>

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementors

impl Reducer<Sum0> for ReduceA0

type Output = ()

type Async = ReduceA0Async

fn into_async(self) -> Self::Async

impl Reducer<bool> for BoolAndReducer

type Output = bool

type Async = BoolAndReducerAsync

fn into_async(self) -> Self::Async

impl Reducer<bool> for BoolOrReducer

type Output = bool

type Async = BoolOrReducerAsync

fn into_async(self) -> Self::Async

impl Reducer<()> for ReduceC0

type Output = ()

type Async = ReduceC0Async

fn into_async(self) -> Self::Async

impl<A, C> Reducer<A> for FolderSyncReducer<A, C> where
    C: FolderSync<A>, 

type Output = C::Output

type Async = FolderSyncReducerAsync<A, C, C::Output>

fn into_async(self) -> Self::Async

impl<A, F> Reducer<A> for AllReducer<A, F> where
    F: FnMut(A) -> bool, 

type Output = bool

type Async = AllReducerAsync<A, F>

fn into_async(self) -> Self::Async

impl<A, F> Reducer<A> for AnyReducer<A, F> where
    F: FnMut(A) -> bool, 

type Output = bool

type Async = AnyReducerAsync<A, F>

fn into_async(self) -> Self::Async

impl<A, F> Reducer<A> for ForEachReducer<A, F> where
    F: FnMut(A) + Clone, 

type Output = ()

type Async = Self

fn into_async(self) -> Self::Async

impl<A, T: Default + Extend<A>> Reducer<A> for PushReducer<A, T>

type Output = T

type Async = PushReducerAsync<A, T>

fn into_async(self) -> Self::Async

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> Reducer<Sum8<S0, S1, S2, S3, S4, S5, S6, S7>> for ReduceA8<A, B, C, D, E, F, G, H>

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

type Async = ReduceA8Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, G::Async, H::Async, S0, S1, S2, S3, S4, S5, S6, S7>

fn into_async(self) -> Self::Async

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> Reducer<(S0, S1, S2, S3, S4, S5, S6, S7)> for ReduceC8<A, B, C, D, E, F, G, H>

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

type Async = ReduceC8Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, G::Async, H::Async, S0, S1, S2, S3, S4, S5, S6, S7>

fn into_async(self) -> Self::Async

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> Reducer<Sum7<S0, S1, S2, S3, S4, S5, S6>> for ReduceA7<A, B, C, D, E, F, G>

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

type Async = ReduceA7Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, G::Async, S0, S1, S2, S3, S4, S5, S6>

fn into_async(self) -> Self::Async

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> Reducer<(S0, S1, S2, S3, S4, S5, S6)> for ReduceC7<A, B, C, D, E, F, G>

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

type Async = ReduceC7Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, G::Async, S0, S1, S2, S3, S4, S5, S6>

fn into_async(self) -> Self::Async

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> Reducer<Sum6<S0, S1, S2, S3, S4, S5>> for ReduceA6<A, B, C, D, E, F>

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

type Async = ReduceA6Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, S0, S1, S2, S3, S4, S5>

fn into_async(self) -> Self::Async

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> Reducer<(S0, S1, S2, S3, S4, S5)> for ReduceC6<A, B, C, D, E, F>

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

type Async = ReduceC6Async<A::Async, B::Async, C::Async, D::Async, E::Async, F::Async, S0, S1, S2, S3, S4, S5>

fn into_async(self) -> Self::Async

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, E: Reducer<S4>, S0, S1, S2, S3, S4> Reducer<Sum5<S0, S1, S2, S3, S4>> for ReduceA5<A, B, C, D, E>

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

type Async = ReduceA5Async<A::Async, B::Async, C::Async, D::Async, E::Async, S0, S1, S2, S3, S4>

fn into_async(self) -> Self::Async

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

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

type Async = ReduceC5Async<A::Async, B::Async, C::Async, D::Async, E::Async, S0, S1, S2, S3, S4>

fn into_async(self) -> Self::Async

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, D: Reducer<S3>, S0, S1, S2, S3> Reducer<Sum4<S0, S1, S2, S3>> for ReduceA4<A, B, C, D>

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

type Async = ReduceA4Async<A::Async, B::Async, C::Async, D::Async, S0, S1, S2, S3>

fn into_async(self) -> Self::Async

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

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

type Async = ReduceC4Async<A::Async, B::Async, C::Async, D::Async, S0, S1, S2, S3>

fn into_async(self) -> Self::Async

impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> Reducer<Sum3<S0, S1, S2>> for ReduceA3<A, B, C>

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

type Async = ReduceA3Async<A::Async, B::Async, C::Async, S0, S1, S2>

fn into_async(self) -> Self::Async

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

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

type Async = ReduceC3Async<A::Async, B::Async, C::Async, S0, S1, S2>

fn into_async(self) -> Self::Async

impl<A: Reducer<S0>, B: Reducer<S1>, S0, S1> Reducer<Sum2<S0, S1>> for ReduceA2<A, B>

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

type Async = ReduceA2Async<A::Async, B::Async, S0, S1>

fn into_async(self) -> Self::Async

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

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

type Async = ReduceC2Async<A::Async, B::Async, S0, S1>

fn into_async(self) -> Self::Async

impl<A: Reducer<S0>, S0> Reducer<Sum1<S0>> for ReduceA1<A>

type Output = (A::Output,)

type Async = ReduceA1Async<A::Async, S0>

fn into_async(self) -> Self::Async

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

type Output = (A::Output,)

type Async = ReduceC1Async<A::Async, S0>

fn into_async(self) -> Self::Async

impl<A: IntoIterator<Item = B>, T: Default + Extend<B>, B> Reducer<A> for ExtendReducer<A, T>

type Output = T

type Async = ExtendReducerAsync<A, T>

fn into_async(self) -> Self::Async

impl<P, R, T, U> Reducer<(T, U)> for GroupByReducerA<P, R, T, U> where
    P: PipeTask<U>,
    R: Reducer<P::Item> + Clone,
    T: Eq + Hash, 

type Output = HashMap<T, R::Output>

type Async = GroupByReducerAAsync<P::Async, R, R::Async, T, U>

fn into_async(self) -> Self::Async

impl<R, T, U> Reducer<HashMap<T, U, RandomState>> for GroupByReducerB<R, T, U> where
    R: Reducer<U> + Clone,
    T: Eq + Hash, 

type Output = HashMap<T, R::Output>

type Async = GroupByReducerBAsync<R, R::Async, T, U>

fn into_async(self) -> Self::Async

impl<R: Reducer<Item>, E, Item> Reducer<Result<Item, E>> for ResultReducer<R, E>

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

type Async = ResultReducerAsync<R::Async, E>

fn into_async(self) -> Self::Async

impl<R: Reducer<Item>, Item> Reducer<Option<Item>> for OptionReducer<R>

type Output = Option<R::Output>

type Async = OptionReducerAsync<R::Async>

fn into_async(self) -> Self::Async

impl<R: Reducer<Item>, T, Item> Reducer<Item> for IntoReducer<R, T> where
    R::Output: Into<T>, 

type Output = T

type Async = IntoReducerAsync<R::Async, T>

fn into_async(self) -> Self::Async

Loading content...