[][src]Trait amadeus::par_sink::Reducer

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

Associated Types

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementors

impl Reducer for BoolAndReducer[src]

impl Reducer for BoolOrReducer[src]

impl Reducer for ReduceA0[src]

impl Reducer for ReduceC0[src]

type Item = ()

type Output = ()

type Async = ReduceC0Async

impl<A> Reducer for ReduceA1<A> where
    A: Reducer
[src]

type Item = Sum1<<A as Reducer>::Item>

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

type Async = ReduceA1Async<<A as Reducer>::Async>

impl<A> Reducer for ReduceC1<A> where
    A: Reducer
[src]

type Item = (<A as Reducer>::Item,)

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

type Async = ReduceC1Async<<A as Reducer>::Async>

impl<A, B> Reducer for ReduceA2<A, B> where
    A: Reducer,
    B: Reducer
[src]

type Item = Sum2<<A as Reducer>::Item, <B as Reducer>::Item>

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

type Async = ReduceA2Async<<A as Reducer>::Async, <B as Reducer>::Async>

impl<A, B> Reducer for ReduceC2<A, B> where
    A: Reducer,
    B: Reducer
[src]

type Item = (<A as Reducer>::Item, <B as Reducer>::Item)

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

type Async = ReduceC2Async<<A as Reducer>::Async, <B as Reducer>::Async>

impl<A, B, C> Reducer for ReduceA3<A, B, C> where
    A: Reducer,
    B: Reducer,
    C: Reducer
[src]

type Item = Sum3<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item>

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

type Async = ReduceA3Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async>

impl<A, B, C> Reducer for ReduceC3<A, B, C> where
    A: Reducer,
    B: Reducer,
    C: Reducer
[src]

type Item = (<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item)

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

type Async = ReduceC3Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async>

impl<A, B, C, D> Reducer for ReduceA4<A, B, C, D> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer
[src]

type Item = Sum4<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item>

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

type Async = ReduceA4Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async>

impl<A, B, C, D> Reducer for ReduceC4<A, B, C, D> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer
[src]

type Item = (<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item)

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

type Async = ReduceC4Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async>

impl<A, B, C, D, E> Reducer for ReduceA5<A, B, C, D, E> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer
[src]

type Item = Sum5<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item>

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

type Async = ReduceA5Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async>

impl<A, B, C, D, E> Reducer for ReduceC5<A, B, C, D, E> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer
[src]

type Item = (<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item)

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

type Async = ReduceC5Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async>

impl<A, B, C, D, E, F> Reducer for ReduceA6<A, B, C, D, E, F> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer
[src]

type Item = Sum6<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item, <F as Reducer>::Item>

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

type Async = ReduceA6Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async>

impl<A, B, C, D, E, F> Reducer for ReduceC6<A, B, C, D, E, F> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer
[src]

type Item = (<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item, <F as Reducer>::Item)

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

type Async = ReduceC6Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async>

impl<A, B, C, D, E, F, G> Reducer for ReduceA7<A, B, C, D, E, F, G> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer,
    G: Reducer
[src]

type Item = Sum7<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item, <F as Reducer>::Item, <G as Reducer>::Item>

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

type Async = ReduceA7Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async, <G as Reducer>::Async>

impl<A, B, C, D, E, F, G> Reducer for ReduceC7<A, B, C, D, E, F, G> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer,
    G: Reducer
[src]

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

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

type Async = ReduceC7Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async, <G as Reducer>::Async>

impl<A, B, C, D, E, F, G, H> Reducer for ReduceA8<A, B, C, D, E, F, G, H> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer,
    G: Reducer,
    H: Reducer
[src]

type Item = Sum8<<A as Reducer>::Item, <B as Reducer>::Item, <C as Reducer>::Item, <D as Reducer>::Item, <E as Reducer>::Item, <F as Reducer>::Item, <G as Reducer>::Item, <H as Reducer>::Item>

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

type Async = ReduceA8Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async, <G as Reducer>::Async, <H as Reducer>::Async>

impl<A, B, C, D, E, F, G, H> Reducer for ReduceC8<A, B, C, D, E, F, G, H> where
    A: Reducer,
    B: Reducer,
    C: Reducer,
    D: Reducer,
    E: Reducer,
    F: Reducer,
    G: Reducer,
    H: Reducer
[src]

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

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

type Async = ReduceC8Async<<A as Reducer>::Async, <B as Reducer>::Async, <C as Reducer>::Async, <D as Reducer>::Async, <E as Reducer>::Async, <F as Reducer>::Async, <G as Reducer>::Async, <H as Reducer>::Async>

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

type Item = A

type Output = <C as FolderSync<A>>::Output

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

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

type Item = A

type Output = bool

type Async = AllReducer<A, F>

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

type Item = A

type Output = bool

type Async = AnyReducer<A, F>

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

type Item = A

type Output = ()

type Async = ForEachReducer<A, F>

impl<A, T> Reducer for PushReducer<A, T> where
    T: Extend<A>, 
[src]

type Item = A

type Output = T

type Async = PushReducer<A, T>

impl<A, T, B> Reducer for ExtendReducer<A, T> where
    A: IntoIterator<Item = B>,
    T: Extend<B>, 
[src]

type Item = A

type Output = T

type Async = ExtendReducer<A, T>

impl<R> Reducer for OptionReducer<R> where
    R: Reducer
[src]

type Item = Option<<R as Reducer>::Item>

type Output = Option<<R as Reducer>::Output>

type Async = OptionReducer<<R as Reducer>::Async>

impl<R, E> Reducer for ResultReducer<R, E> where
    R: Reducer
[src]

type Item = Result<<R as Reducer>::Item, E>

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

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

impl<R, T> Reducer for IntoReducer<R, T> where
    R: Reducer,
    <R as Reducer>::Output: Into<T>, 
[src]

type Item = <R as Reducer>::Item

type Output = T

type Async = IntoReducer<<R as Reducer>::Async, T>

Loading content...