[−][src]Trait amadeus::par_sink::ReducerSend
Associated Types
Loading content...Implementors
impl ReducerSend<Sum0> for ReduceA0
[src]
impl ReducerSend<bool> for BoolAndReducer
[src]
impl ReducerSend<bool> for BoolOrReducer
[src]
impl ReducerSend<()> for ReduceC0
[src]
impl<A, B, C, D, E, F, G, H, 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: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
G: Reducer<S6>,
H: Reducer<S7>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
<G as Reducer<S6>>::Done: Send,
<G as Reducer<S6>>::Done: 'static,
<H as Reducer<S7>>::Done: Send,
<H as Reducer<S7>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
G: Reducer<S6>,
H: Reducer<S7>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
<G as Reducer<S6>>::Done: Send,
<G as Reducer<S6>>::Done: 'static,
<H as Reducer<S7>>::Done: Send,
<H as Reducer<S7>>::Done: 'static,
type Done = (<A as Reducer<S0>>::Done, <B as Reducer<S1>>::Done, <C as Reducer<S2>>::Done, <D as Reducer<S3>>::Done, <E as Reducer<S4>>::Done, <F as Reducer<S5>>::Done, <G as Reducer<S6>>::Done, <H as Reducer<S7>>::Done)
impl<A, B, C, D, E, F, G, H, 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> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
G: ReducerSend<S6>,
H: ReducerSend<S7>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
G: ReducerSend<S6>,
H: ReducerSend<S7>,
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, B, C, D, E, F, G, 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: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
G: Reducer<S6>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
<G as Reducer<S6>>::Done: Send,
<G as Reducer<S6>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
G: Reducer<S6>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
<G as Reducer<S6>>::Done: Send,
<G as Reducer<S6>>::Done: 'static,
type Done = (<A as Reducer<S0>>::Done, <B as Reducer<S1>>::Done, <C as Reducer<S2>>::Done, <D as Reducer<S3>>::Done, <E as Reducer<S4>>::Done, <F as Reducer<S5>>::Done, <G as Reducer<S6>>::Done)
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> ReducerSend<(S0, S1, S2, S3, S4, S5, S6)> for ReduceC7<A, B, C, D, E, F, G> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
G: ReducerSend<S6>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
G: ReducerSend<S6>,
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, B, C, D, E, F, S0, S1, S2, S3, S4, S5> ReducerSend<Sum6<S0, S1, S2, S3, S4, S5>> for ReduceA6<A, B, C, D, E, F> where
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
F: Reducer<S5>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
<F as Reducer<S5>>::Done: Send,
<F as Reducer<S5>>::Done: 'static,
type Done = (<A as Reducer<S0>>::Done, <B as Reducer<S1>>::Done, <C as Reducer<S2>>::Done, <D as Reducer<S3>>::Done, <E as Reducer<S4>>::Done, <F as Reducer<S5>>::Done)
impl<A, B, C, D, E, F, S0, S1, S2, S3, S4, S5> ReducerSend<(S0, S1, S2, S3, S4, S5)> for ReduceC6<A, B, C, D, E, F> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
F: ReducerSend<S5>,
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, B, C, D, E, S0, S1, S2, S3, S4> ReducerSend<Sum5<S0, S1, S2, S3, S4>> for ReduceA5<A, B, C, D, E> where
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
E: Reducer<S4>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
<E as Reducer<S4>>::Done: Send,
<E as Reducer<S4>>::Done: 'static,
type Done = (<A as Reducer<S0>>::Done, <B as Reducer<S1>>::Done, <C as Reducer<S2>>::Done, <D as Reducer<S3>>::Done, <E as Reducer<S4>>::Done)
impl<A, B, C, D, E, S0, S1, S2, S3, S4> ReducerSend<(S0, S1, S2, S3, S4)> for ReduceC5<A, B, C, D, E> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
E: ReducerSend<S4>,
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, B, C, D, S0, S1, S2, S3> ReducerSend<Sum4<S0, S1, S2, S3>> for ReduceA4<A, B, C, D> where
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
D: Reducer<S3>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
<D as Reducer<S3>>::Done: Send,
<D as Reducer<S3>>::Done: 'static,
type Done = (<A as Reducer<S0>>::Done, <B as Reducer<S1>>::Done, <C as Reducer<S2>>::Done, <D as Reducer<S3>>::Done)
impl<A, B, C, D, S0, S1, S2, S3> ReducerSend<(S0, S1, S2, S3)> for ReduceC4<A, B, C, D> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
D: ReducerSend<S3>,
type Done = (<A as ReducerSend<S0>>::Done, <B as ReducerSend<S1>>::Done, <C as ReducerSend<S2>>::Done, <D as ReducerSend<S3>>::Done)
impl<A, B, C, S0, S1, S2> ReducerSend<Sum3<S0, S1, S2>> for ReduceA3<A, B, C> where
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
C: Reducer<S2>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
<C as Reducer<S2>>::Done: Send,
<C as Reducer<S2>>::Done: 'static,
impl<A, B, C, S0, S1, S2> ReducerSend<(S0, S1, S2)> for ReduceC3<A, B, C> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
C: ReducerSend<S2>,
type Done = (<A as ReducerSend<S0>>::Done, <B as ReducerSend<S1>>::Done, <C as ReducerSend<S2>>::Done)
impl<A, B, S0, S1> ReducerSend<Sum2<S0, S1>> for ReduceA2<A, B> where
A: Reducer<S0>,
B: Reducer<S1>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
[src]
A: Reducer<S0>,
B: Reducer<S1>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
<B as Reducer<S1>>::Done: Send,
<B as Reducer<S1>>::Done: 'static,
impl<A, B, S0, S1> ReducerSend<(S0, S1)> for ReduceC2<A, B> where
A: ReducerSend<S0>,
B: ReducerSend<S1>,
[src]
A: ReducerSend<S0>,
B: ReducerSend<S1>,
type Done = (<A as ReducerSend<S0>>::Done, <B as ReducerSend<S1>>::Done)
impl<A, S0> ReducerSend<Sum1<S0>> for ReduceA1<A> where
A: Reducer<S0>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
[src]
A: Reducer<S0>,
<A as Reducer<S0>>::Done: Send,
<A as Reducer<S0>>::Done: 'static,
impl<A, S0> ReducerSend<(S0,)> for ReduceC1<A> where
A: ReducerSend<S0>,
[src]
A: ReducerSend<S0>,
type Done = (<A as ReducerSend<S0>>::Done,)
impl<Item, F> ReducerSend<Item> for AllReducer<Item, F> where
F: FnMut<(Item,), Output = bool>,
[src]
F: FnMut<(Item,), Output = bool>,
impl<Item, F> ReducerSend<Item> for AnyReducer<Item, F> where
F: FnMut<(Item,), Output = bool>,
[src]
F: FnMut<(Item,), Output = bool>,
impl<Item, F> ReducerSend<Item> for FolderSyncReducer<Item, F, Final> where
F: FolderSync<Item>,
<F as FolderSync<Item>>::Done: Send,
<F as FolderSync<Item>>::Done: 'static,
[src]
F: FolderSync<Item>,
<F as FolderSync<Item>>::Done: Send,
<F as FolderSync<Item>>::Done: 'static,
type Done = <F as FolderSync<Item>>::Done
impl<Item, F> ReducerSend<Item> for FolderSyncReducer<Item, F, Inter> where
F: FolderSync<Item>,
<F as FolderSync<Item>>::State: Send,
<F as FolderSync<Item>>::State: 'static,
[src]
F: FolderSync<Item>,
<F as FolderSync<Item>>::State: Send,
<F as FolderSync<Item>>::State: 'static,
type Done = <F as FolderSync<Item>>::State
impl<Item, F> ReducerSend<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]
F: FnMut<(Item,), Output = ()>,
impl<Item, T> ReducerSend<Item> for PushReducer<Item, T> where
T: Default + Extend<Item> + Send + 'static,
[src]
T: Default + Extend<Item> + Send + 'static,
type Done = T
impl<Item, T, B> ReducerSend<Item> for ExtendReducer<Item, T> where
Item: IntoIterator<Item = B>,
T: Default + Extend<B> + Send + 'static,
[src]
Item: IntoIterator<Item = B>,
T: Default + Extend<B> + 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 as PipeTask<U>>::Output> + Clone,
T: Eq + Hash + Send + 'static,
<R as Reducer<<P as PipeTask<U>>::Output>>::Done: Send,
<R as Reducer<<P as PipeTask<U>>::Output>>::Done: 'static,
[src]
P: PipeTask<U>,
R: Reducer<<P as PipeTask<U>>::Output> + Clone,
T: Eq + Hash + Send + 'static,
<R as Reducer<<P as PipeTask<U>>::Output>>::Done: Send,
<R as Reducer<<P as PipeTask<U>>::Output>>::Done: 'static,
impl<R, E, Item> ReducerSend<Result<Item, E>> for ResultReducer<R, E> where
E: Send + 'static,
R: Reducer<Item>,
<R as Reducer<Item>>::Done: Send,
<R as Reducer<Item>>::Done: 'static,
[src]
E: Send + 'static,
R: Reducer<Item>,
<R as Reducer<Item>>::Done: Send,
<R as Reducer<Item>>::Done: 'static,
impl<R, Item> ReducerSend<Option<Item>> for OptionReducer<R> where
R: Reducer<Item>,
<R as Reducer<Item>>::Done: Send,
<R as Reducer<Item>>::Done: 'static,
[src]
R: Reducer<Item>,
<R as Reducer<Item>>::Done: Send,
<R as Reducer<Item>>::Done: 'static,
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 as Reducer<U>>::Done: Send,
<R as Reducer<U>>::Done: 'static,
[src]
R: Reducer<U> + Clone,
T: Eq + Hash + Send + 'static,
<R as Reducer<U>>::Done: Send,
<R as Reducer<U>>::Done: 'static,