Trait amadeus_core::par_sink::Reducer [−][src]
#[must_use] pub trait Reducer<Item> { type Done; type Async: Sink<Item, Done = Self::Done>; fn into_async(self) -> Self::Async; }
Associated Types
Required methods
fn into_async(self) -> Self::Async
[src]
fn into_async(self) -> Self::Async
[src]Implementors
impl Reducer<bool> for BoolAndReducer
[src]
impl Reducer<bool> for BoolAndReducer
[src]impl Reducer<bool> for BoolOrReducer
[src]
impl Reducer<bool> for BoolOrReducer
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]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>
[src]
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>
[src]impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> Reducer<Sum3<S0, S1, S2>> for ReduceA3<A, B, C>
[src]
impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> Reducer<Sum3<S0, S1, S2>> for ReduceA3<A, B, C>
[src]impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> Reducer<(S0, S1, S2)> for ReduceC3<A, B, C>
[src]
impl<A: Reducer<S0>, B: Reducer<S1>, C: Reducer<S2>, S0, S1, S2> Reducer<(S0, S1, S2)> for ReduceC3<A, B, C>
[src]impl<A: Reducer<S0>, S0> Reducer<Sum1<S0>> for ReduceA1<A>
[src]
impl<A: Reducer<S0>, S0> Reducer<Sum1<S0>> for ReduceA1<A>
[src]type Done = (A::Done,)
type Async = ReduceA1Async<A::Async, S0>
fn into_async(self) -> Self::Async
[src]
impl<A: Reducer<S0>, S0> Reducer<(S0,)> for ReduceC1<A>
[src]
impl<A: Reducer<S0>, S0> Reducer<(S0,)> for ReduceC1<A>
[src]type Done = (A::Done,)
type Async = ReduceC1Async<A::Async, S0>
fn into_async(self) -> Self::Async
[src]
impl<Item, F> Reducer<Item> for FolderSyncReducer<Item, F, Final> where
F: FolderSync<Item>,
[src]
impl<Item, F> Reducer<Item> for FolderSyncReducer<Item, F, Final> where
F: FolderSync<Item>,
[src]type Done = F::Done
type Async = FolderSyncReducerAsync<Item, F, F::State, Final>
fn into_async(self) -> Self::Async
[src]
impl<Item, F> Reducer<Item> for FolderSyncReducer<Item, F, Inter> where
F: FolderSync<Item>,
[src]
impl<Item, F> Reducer<Item> for FolderSyncReducer<Item, F, Inter> where
F: FolderSync<Item>,
[src]type Done = F::State
type Async = FolderSyncReducerAsync<Item, F, F::State, Inter>
fn into_async(self) -> Self::Async
[src]
impl<Item, T: Default + Extend<Item>> Reducer<Item> for PushReducer<Item, T>
[src]
impl<Item, T: Default + Extend<Item>> Reducer<Item> for PushReducer<Item, T>
[src]impl<Item: IntoIterator<Item = B>, T: Default + Extend<B>, B> Reducer<Item> for ExtendReducer<Item, T>
[src]
impl<Item: IntoIterator<Item = B>, T: Default + Extend<B>, B> Reducer<Item> for ExtendReducer<Item, T>
[src]impl<P, R, T, U> Reducer<(T, U)> for GroupByReducerA<P, R, T, U> where
P: PipeTask<U>,
R: Reducer<P::Output> + Clone,
T: Eq + Hash,
[src]
impl<P, R, T, U> Reducer<(T, U)> for GroupByReducerA<P, R, T, U> where
P: PipeTask<U>,
R: Reducer<P::Output> + Clone,
T: Eq + Hash,
[src]type Done = IndexMap<T, R::Done>
type Async = GroupByReducerAAsync<P::Async, R, T, U>
fn into_async(self) -> Self::Async
[src]
impl<R, T, U> Reducer<IndexMap<T, U, RandomState>> for GroupByReducerB<R, T, U> where
R: Reducer<U> + Clone,
T: Eq + Hash,
[src]
impl<R, T, U> Reducer<IndexMap<T, U, RandomState>> for GroupByReducerB<R, T, U> where
R: Reducer<U> + Clone,
T: Eq + Hash,
[src]type Done = IndexMap<T, R::Done>
type Async = GroupByReducerBAsync<R, T, U>
fn into_async(self) -> Self::Async
[src]
impl<R: Reducer<Item>, E, Item> Reducer<Result<Item, E>> for ResultReducer<R, E>
[src]
impl<R: Reducer<Item>, E, Item> Reducer<Result<Item, E>> for ResultReducer<R, E>
[src]type Done = Result<R::Done, E>
type Async = ResultReducerAsync<R::Async, E>
fn into_async(self) -> Self::Async
[src]
impl<R: Reducer<Item>, Item> Reducer<Option<Item>> for OptionReducer<R>
[src]
impl<R: Reducer<Item>, Item> Reducer<Option<Item>> for OptionReducer<R>
[src]