[−][src]Trait amadeus::par_sink::ParallelSink
Associated Types
type Done
type Pipe: ParallelPipe<Item>
type ReduceA: ReducerSend<<Self::Pipe as ParallelPipe<Item>>::Output> + Clone + Send
type ReduceC: Reducer<<Self::ReduceA as ReducerSend<<Self::Pipe as ParallelPipe<Item>>::Output>>::Done>
Required methods
Loading content...Implementations on Foreign Types
impl<Item, R0, R1, R2, R3, R4, R5, R6, O0, O1, O2, O3, O4, O5, O6> ParallelSink<Item> for (R0, R1, R2, R3, R4, R5, R6) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
R6: ParallelSink<Item, Done = O6>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
R6: ParallelSink<Item, Done = O6>,
type Done = (O0, O1, O2, O3, O4, O5, O6)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe, <R3 as ParallelSink<Item>>::Pipe, <R4 as ParallelSink<Item>>::Pipe, <R5 as ParallelSink<Item>>::Pipe, <R6 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA7<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA, <R3 as ParallelSink<Item>>::ReduceA, <R4 as ParallelSink<Item>>::ReduceA, <R5 as ParallelSink<Item>>::ReduceA, <R6 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC7<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC, <R3 as ParallelSink<Item>>::ReduceC, <R4 as ParallelSink<Item>>::ReduceC, <R5 as ParallelSink<Item>>::ReduceC, <R6 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5, R6) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, R2, R3, R4, R5, R6, R7, O0, O1, O2, O3, O4, O5, O6, O7> ParallelSink<Item> for (R0, R1, R2, R3, R4, R5, R6, R7) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
R6: ParallelSink<Item, Done = O6>,
R7: ParallelSink<Item, Done = O7>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
R6: ParallelSink<Item, Done = O6>,
R7: ParallelSink<Item, Done = O7>,
type Done = (O0, O1, O2, O3, O4, O5, O6, O7)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe, <R3 as ParallelSink<Item>>::Pipe, <R4 as ParallelSink<Item>>::Pipe, <R5 as ParallelSink<Item>>::Pipe, <R6 as ParallelSink<Item>>::Pipe, <R7 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA8<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA, <R3 as ParallelSink<Item>>::ReduceA, <R4 as ParallelSink<Item>>::ReduceA, <R5 as ParallelSink<Item>>::ReduceA, <R6 as ParallelSink<Item>>::ReduceA, <R7 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC8<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC, <R3 as ParallelSink<Item>>::ReduceC, <R4 as ParallelSink<Item>>::ReduceC, <R5 as ParallelSink<Item>>::ReduceC, <R6 as ParallelSink<Item>>::ReduceC, <R7 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5, R6, R7) as ParallelSink<Item>>::ReduceC)
impl<Item> ParallelSink<Item> for ()
[src]
type Done = ()
type Pipe = ()
type ReduceA = ReduceA0
type ReduceC = ReduceC0
fn reducers(
self
) -> (<() as ParallelSink<Item>>::Pipe, <() as ParallelSink<Item>>::ReduceA, <() as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<() as ParallelSink<Item>>::Pipe, <() as ParallelSink<Item>>::ReduceA, <() as ParallelSink<Item>>::ReduceC)
impl<Item, R0, O0> ParallelSink<Item> for (R0,) where
R0: ParallelSink<Item, Done = O0>,
[src]
R0: ParallelSink<Item, Done = O0>,
type Done = (O0,)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe,)
type ReduceA = ReduceA1<<R0 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC1<<R0 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0,) as ParallelSink<Item>>::Pipe, <(R0,) as ParallelSink<Item>>::ReduceA, <(R0,) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0,) as ParallelSink<Item>>::Pipe, <(R0,) as ParallelSink<Item>>::ReduceA, <(R0,) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, R2, O0, O1, O2> ParallelSink<Item> for (R0, R1, R2) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
type Done = (O0, O1, O2)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA3<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC3<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2) as ParallelSink<Item>>::Pipe, <(R0, R1, R2) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2) as ParallelSink<Item>>::Pipe, <(R0, R1, R2) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, R2, R3, R4, O0, O1, O2, O3, O4> ParallelSink<Item> for (R0, R1, R2, R3, R4) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
type Done = (O0, O1, O2, O3, O4)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe, <R3 as ParallelSink<Item>>::Pipe, <R4 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA5<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA, <R3 as ParallelSink<Item>>::ReduceA, <R4 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC5<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC, <R3 as ParallelSink<Item>>::ReduceC, <R4 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2, R3, R4) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2, R3, R4) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, R2, R3, O0, O1, O2, O3> ParallelSink<Item> for (R0, R1, R2, R3) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
type Done = (O0, O1, O2, O3)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe, <R3 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA4<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA, <R3 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC4<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC, <R3 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2, R3) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2, R3) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, R2, R3, R4, R5, O0, O1, O2, O3, O4, O5> ParallelSink<Item> for (R0, R1, R2, R3, R4, R5) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
R2: ParallelSink<Item, Done = O2>,
R3: ParallelSink<Item, Done = O3>,
R4: ParallelSink<Item, Done = O4>,
R5: ParallelSink<Item, Done = O5>,
type Done = (O0, O1, O2, O3, O4, O5)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe, <R2 as ParallelSink<Item>>::Pipe, <R3 as ParallelSink<Item>>::Pipe, <R4 as ParallelSink<Item>>::Pipe, <R5 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA6<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA, <R2 as ParallelSink<Item>>::ReduceA, <R3 as ParallelSink<Item>>::ReduceA, <R4 as ParallelSink<Item>>::ReduceA, <R5 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC6<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC, <R2 as ParallelSink<Item>>::ReduceC, <R3 as ParallelSink<Item>>::ReduceC, <R4 as ParallelSink<Item>>::ReduceC, <R5 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::Pipe, <(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::ReduceA, <(R0, R1, R2, R3, R4, R5) as ParallelSink<Item>>::ReduceC)
impl<Item, R0, R1, O0, O1> ParallelSink<Item> for (R0, R1) where
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
[src]
Item: Copy,
R0: ParallelSink<Item, Done = O0>,
R1: ParallelSink<Item, Done = O1>,
type Done = (O0, O1)
type Pipe = (<R0 as ParallelSink<Item>>::Pipe, <R1 as ParallelSink<Item>>::Pipe)
type ReduceA = ReduceA2<<R0 as ParallelSink<Item>>::ReduceA, <R1 as ParallelSink<Item>>::ReduceA>
type ReduceC = ReduceC2<<R0 as ParallelSink<Item>>::ReduceC, <R1 as ParallelSink<Item>>::ReduceC>
fn reducers(
self
) -> (<(R0, R1) as ParallelSink<Item>>::Pipe, <(R0, R1) as ParallelSink<Item>>::ReduceA, <(R0, R1) as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<(R0, R1) as ParallelSink<Item>>::Pipe, <(R0, R1) as ParallelSink<Item>>::ReduceA, <(R0, R1) as ParallelSink<Item>>::ReduceC)
Implementors
impl<A, B, C, Item, RefAItem> ParallelSink<Item> for Fork<A, B, C, RefAItem> where
A: ParallelPipe<Item>,
B: ParallelSink<<A as ParallelPipe<Item>>::Output>,
C: ParallelSink<RefAItem>,
RefAItem: 'static,
[src]
A: ParallelPipe<Item>,
B: ParallelSink<<A as ParallelPipe<Item>>::Output>,
C: ParallelSink<RefAItem>,
RefAItem: 'static,
type Done = (<B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::Done, <C as ParallelSink<RefAItem>>::Done)
type Pipe = Fork<A, <B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::Pipe, <C as ParallelSink<RefAItem>>::Pipe, RefAItem>
type ReduceA = ReduceA2<<B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::ReduceA, <C as ParallelSink<RefAItem>>::ReduceA>
type ReduceC = ReduceC2<<B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::ReduceC, <C as ParallelSink<RefAItem>>::ReduceC>
fn reducers(
self
) -> (<Fork<A, B, C, RefAItem> as ParallelSink<Item>>::Pipe, <Fork<A, B, C, RefAItem> as ParallelSink<Item>>::ReduceA, <Fork<A, B, C, RefAItem> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<Fork<A, B, C, RefAItem> as ParallelSink<Item>>::Pipe, <Fork<A, B, C, RefAItem> as ParallelSink<Item>>::ReduceA, <Fork<A, B, C, RefAItem> as ParallelSink<Item>>::ReduceC)
impl<A, B, Item> ParallelSink<Item> for Pipe<A, B> where
A: ParallelPipe<Item>,
B: ParallelSink<<A as ParallelPipe<Item>>::Output>,
[src]
A: ParallelPipe<Item>,
B: ParallelSink<<A as ParallelPipe<Item>>::Output>,
type Done = <B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::Done
type Pipe = Pipe<A, <B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::Pipe>
type ReduceA = <B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::ReduceA
type ReduceC = <B as ParallelSink<<A as ParallelPipe<Item>>::Output>>::ReduceC
fn reducers(
self
) -> (<Pipe<A, B> as ParallelSink<Item>>::Pipe, <Pipe<A, B> as ParallelSink<Item>>::ReduceA, <Pipe<A, B> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<Pipe<A, B> as ParallelSink<Item>>::Pipe, <Pipe<A, B> as ParallelSink<Item>>::ReduceA, <Pipe<A, B> as ParallelSink<Item>>::ReduceC)
impl<A, B, Item, T, U> ParallelSink<Item> for GroupBy<A, B> where
A: ParallelPipe<Item, Output = (T, U)>,
B: ParallelSink<U>,
T: Eq + Hash + Send + 'static,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: Clone,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: Send,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: 'static,
<B as ParallelSink<U>>::ReduceA: Clone,
<B as ParallelSink<U>>::ReduceA: Send,
<B as ParallelSink<U>>::ReduceA: 'static,
<B as ParallelSink<U>>::ReduceC: Clone,
<B as ParallelSink<U>>::Done: Send,
<B as ParallelSink<U>>::Done: 'static,
[src]
A: ParallelPipe<Item, Output = (T, U)>,
B: ParallelSink<U>,
T: Eq + Hash + Send + 'static,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: Clone,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: Send,
<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task: 'static,
<B as ParallelSink<U>>::ReduceA: Clone,
<B as ParallelSink<U>>::ReduceA: Send,
<B as ParallelSink<U>>::ReduceA: 'static,
<B as ParallelSink<U>>::ReduceC: Clone,
<B as ParallelSink<U>>::Done: Send,
<B as ParallelSink<U>>::Done: 'static,
type Done = IndexMap<T, <B as ParallelSink<U>>::Done, RandomState>
type Pipe = A
type ReduceA = GroupByReducerA<<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Task, <B as ParallelSink<U>>::ReduceA, T, U>
type ReduceC = GroupByReducerB<<B as ParallelSink<U>>::ReduceC, T, <<B as ParallelSink<U>>::ReduceA as ReducerSend<<<B as ParallelSink<U>>::Pipe as ParallelPipe<U>>::Output>>::Done>
fn reducers(
self
) -> (<GroupBy<A, B> as ParallelSink<Item>>::Pipe, <GroupBy<A, B> as ParallelSink<Item>>::ReduceA, <GroupBy<A, B> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<GroupBy<A, B> as ParallelSink<Item>>::Pipe, <GroupBy<A, B> as ParallelSink<Item>>::ReduceA, <GroupBy<A, B> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for Count<P> where
P: ParallelPipe<Item>,
[src]
P: ParallelPipe<Item>,
type Done = <<Count<P> as ParallelSink<Item>>::ReduceC as Reducer<<<Count<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, CountFolder>
type ReduceC = FolderSyncReducer<<<Count<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, SumFolder<usize>>
fn reducers(
self
) -> (P, <Count<P> as ParallelSink<Item>>::ReduceA, <Count<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Count<P> as ParallelSink<Item>>::ReduceA, <Count<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for Histogram<P> where
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Hash,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Hash,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<Histogram<P> as ParallelSink<Item>>::ReduceC as Reducer<<<Histogram<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, HistogramFolder<<P as ParallelPipe<Item>>::Output, StepA>>
type ReduceC = FolderSyncReducer<<<Histogram<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, HistogramFolder<<P as ParallelPipe<Item>>::Output, StepB>>
fn reducers(
self
) -> (P, <Histogram<P> as ParallelSink<Item>>::ReduceA, <Histogram<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Histogram<P> as ParallelSink<Item>>::ReduceA, <Histogram<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for Max<P> where
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<Max<P> as ParallelSink<Item>>::ReduceC as Reducer<<<Max<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, Max<<P as ParallelPipe<Item>>::Output>>
type ReduceC = FolderSyncReducer<<<Max<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, Max<<P as ParallelPipe<Item>>::Output>>
fn reducers(
self
) -> (P, <Max<P> as ParallelSink<Item>>::ReduceA, <Max<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Max<P> as ParallelSink<Item>>::ReduceA, <Max<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for Min<P> where
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Ord,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<Min<P> as ParallelSink<Item>>::ReduceC as Reducer<<<Min<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, Min<<P as ParallelPipe<Item>>::Output>>
type ReduceC = FolderSyncReducer<<<Min<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, Min<<P as ParallelPipe<Item>>::Output>>
fn reducers(
self
) -> (P, <Min<P> as ParallelSink<Item>>::ReduceA, <Min<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Min<P> as ParallelSink<Item>>::ReduceA, <Min<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for MostFrequent<P> where
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Clone,
<P as ParallelPipe<Item>>::Output: Hash,
<P as ParallelPipe<Item>>::Output: Eq,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Clone,
<P as ParallelPipe<Item>>::Output: Hash,
<P as ParallelPipe<Item>>::Output: Eq,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<MostFrequent<P> as ParallelSink<Item>>::ReduceC as Reducer<<<MostFrequent<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MostFrequentFolder>
type ReduceC = FolderSyncReducer<<<MostFrequent<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, SumZeroFolder<Top<<P as ParallelPipe<Item>>::Output, usize>>>
fn reducers(
self
) -> (P, <MostFrequent<P> as ParallelSink<Item>>::ReduceA, <MostFrequent<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MostFrequent<P> as ParallelSink<Item>>::ReduceA, <MostFrequent<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item> ParallelSink<Item> for SampleUnstable<P> where
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<SampleUnstable<P> as ParallelSink<Item>>::ReduceC as Reducer<<<SampleUnstable<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, SampleUnstableFolder>
type ReduceC = FolderSyncReducer<<<SampleUnstable<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, SumFolder<SampleUnstable<<P as ParallelPipe<Item>>::Output>>>
fn reducers(
self
) -> (P, <SampleUnstable<P> as ParallelSink<Item>>::ReduceA, <SampleUnstable<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <SampleUnstable<P> as ParallelSink<Item>>::ReduceA, <SampleUnstable<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item, A, B> ParallelSink<Item> for MostDistinct<P> where
A: Clone + Hash + Eq + Send + 'static,
B: Hash + 'static,
P: ParallelPipe<Item, Output = (A, B)>,
[src]
A: Clone + Hash + Eq + Send + 'static,
B: Hash + 'static,
P: ParallelPipe<Item, Output = (A, B)>,
type Done = <<MostDistinct<P> as ParallelSink<Item>>::ReduceC as Reducer<<<MostDistinct<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MostDistinctFolder>
type ReduceC = FolderSyncReducer<<<MostDistinct<P> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, SumZeroFolder<Top<A, HyperLogLogMagnitude<B>>>>
fn reducers(
self
) -> (P, <MostDistinct<P> as ParallelSink<Item>>::ReduceA, <MostDistinct<P> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MostDistinct<P> as ParallelSink<Item>>::ReduceA, <MostDistinct<P> as ParallelSink<Item>>::ReduceC)
impl<P, Item, B> ParallelSink<Item> for Sum<P, B> where
B: Sum<<P as ParallelPipe<Item>>::Output> + Sum<B> + Send + 'static,
P: ParallelPipe<Item>,
[src]
B: Sum<<P as ParallelPipe<Item>>::Output> + Sum<B> + Send + 'static,
P: ParallelPipe<Item>,
type Done = <<Sum<P, B> as ParallelSink<Item>>::ReduceC as Reducer<<<Sum<P, B> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, SumFolder<B>>
type ReduceC = FolderSyncReducer<<<Sum<P, B> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, SumFolder<B>>
fn reducers(
self
) -> (P, <Sum<P, B> as ParallelSink<Item>>::ReduceA, <Sum<P, B> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Sum<P, B> as ParallelSink<Item>>::ReduceA, <Sum<P, B> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for All<P, F> where
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = bool> + Clone + Send + 'static,
P: ParallelPipe<Item>,
[src]
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = bool> + Clone + Send + 'static,
P: ParallelPipe<Item>,
type Done = bool
type Pipe = P
type ReduceA = AllReducer<<P as ParallelPipe<Item>>::Output, F>
type ReduceC = BoolAndReducer
fn reducers(
self
) -> (<All<P, F> as ParallelSink<Item>>::Pipe, <All<P, F> as ParallelSink<Item>>::ReduceA, <All<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<All<P, F> as ParallelSink<Item>>::Pipe, <All<P, F> as ParallelSink<Item>>::ReduceA, <All<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for Any<P, F> where
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = bool> + Clone + Send + 'static,
P: ParallelPipe<Item>,
[src]
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = bool> + Clone + Send + 'static,
P: ParallelPipe<Item>,
type Done = bool
type Pipe = P
type ReduceA = AnyReducer<<P as ParallelPipe<Item>>::Output, F>
type ReduceC = BoolOrReducer
fn reducers(
self
) -> (<Any<P, F> as ParallelSink<Item>>::Pipe, <Any<P, F> as ParallelSink<Item>>::ReduceA, <Any<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<Any<P, F> as ParallelSink<Item>>::Pipe, <Any<P, F> as ParallelSink<Item>>::ReduceA, <Any<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for Combine<P, F> where
F: FnMut<(<P as ParallelPipe<Item>>::Output, <P as ParallelPipe<Item>>::Output), Output = <P as ParallelPipe<Item>>::Output> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
F: FnMut<(<P as ParallelPipe<Item>>::Output, <P as ParallelPipe<Item>>::Output), Output = <P as ParallelPipe<Item>>::Output> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<Combine<P, F> as ParallelSink<Item>>::ReduceC as Reducer<<<Combine<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, ReduceFn<F, <P as ParallelPipe<Item>>::Output>>
type ReduceC = FolderSyncReducer<<<Combine<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, ReduceFn<F, <P as ParallelPipe<Item>>::Output>>
fn reducers(
self
) -> (P, <Combine<P, F> as ParallelSink<Item>>::ReduceA, <Combine<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Combine<P, F> as ParallelSink<Item>>::ReduceA, <Combine<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for ForEach<P, F> where
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = ()> + Clone + Send + 'static,
P: ParallelPipe<Item>,
[src]
F: FnMut<(<P as ParallelPipe<Item>>::Output,), Output = ()> + Clone + Send + 'static,
P: ParallelPipe<Item>,
type Done = ()
type Pipe = P
type ReduceA = ForEachReducer<<P as ParallelPipe<Item>>::Output, F>
type ReduceC = PushReducer<(), ()>
fn reducers(
self
) -> (<ForEach<P, F> as ParallelSink<Item>>::Pipe, <ForEach<P, F> as ParallelSink<Item>>::ReduceA, <ForEach<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<ForEach<P, F> as ParallelSink<Item>>::Pipe, <ForEach<P, F> as ParallelSink<Item>>::ReduceA, <ForEach<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for MaxBy<P, F> where
F: for<'a, 'b> FnMut<(&'a <P as ParallelPipe<Item>>::Output, &'b <P as ParallelPipe<Item>>::Output), Output = Ordering> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
F: for<'a, 'b> FnMut<(&'a <P as ParallelPipe<Item>>::Output, &'b <P as ParallelPipe<Item>>::Output), Output = Ordering> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<MaxBy<P, F> as ParallelSink<Item>>::ReduceC as Reducer<<<MaxBy<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MaxBy<<P as ParallelPipe<Item>>::Output, F>>
type ReduceC = FolderSyncReducer<<<MaxBy<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, MaxBy<<P as ParallelPipe<Item>>::Output, F>>
fn reducers(
self
) -> (P, <MaxBy<P, F> as ParallelSink<Item>>::ReduceA, <MaxBy<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MaxBy<P, F> as ParallelSink<Item>>::ReduceA, <MaxBy<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F> ParallelSink<Item> for MinBy<P, F> where
F: for<'a, 'b> FnMut<(&'a <P as ParallelPipe<Item>>::Output, &'b <P as ParallelPipe<Item>>::Output), Output = Ordering> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
F: for<'a, 'b> FnMut<(&'a <P as ParallelPipe<Item>>::Output, &'b <P as ParallelPipe<Item>>::Output), Output = Ordering> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<MinBy<P, F> as ParallelSink<Item>>::ReduceC as Reducer<<<MinBy<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MinBy<<P as ParallelPipe<Item>>::Output, F>>
type ReduceC = FolderSyncReducer<<<MinBy<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, MinBy<<P as ParallelPipe<Item>>::Output, F>>
fn reducers(
self
) -> (P, <MinBy<P, F> as ParallelSink<Item>>::ReduceA, <MinBy<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MinBy<P, F> as ParallelSink<Item>>::ReduceA, <MinBy<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F, B> ParallelSink<Item> for MaxByKey<P, F> where
B: Ord + 'static,
F: for<'a> FnMut<(&'a <P as ParallelPipe<Item>>::Output,), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
B: Ord + 'static,
F: for<'a> FnMut<(&'a <P as ParallelPipe<Item>>::Output,), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<MaxByKey<P, F> as ParallelSink<Item>>::ReduceC as Reducer<<<MaxByKey<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MaxByKey<<P as ParallelPipe<Item>>::Output, F, B>>
type ReduceC = FolderSyncReducer<<<MaxByKey<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, MaxByKey<<P as ParallelPipe<Item>>::Output, F, B>>
fn reducers(
self
) -> (P, <MaxByKey<P, F> as ParallelSink<Item>>::ReduceA, <MaxByKey<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MaxByKey<P, F> as ParallelSink<Item>>::ReduceA, <MaxByKey<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, F, B> ParallelSink<Item> for MinByKey<P, F> where
B: Ord + 'static,
F: for<'a> FnMut<(&'a <P as ParallelPipe<Item>>::Output,), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
[src]
B: Ord + 'static,
F: for<'a> FnMut<(&'a <P as ParallelPipe<Item>>::Output,), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
<P as ParallelPipe<Item>>::Output: Send,
<P as ParallelPipe<Item>>::Output: 'static,
type Done = <<MinByKey<P, F> as ParallelSink<Item>>::ReduceC as Reducer<<<MinByKey<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, MinByKey<<P as ParallelPipe<Item>>::Output, F, B>>
type ReduceC = FolderSyncReducer<<<MinByKey<P, F> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, MinByKey<<P as ParallelPipe<Item>>::Output, F, B>>
fn reducers(
self
) -> (P, <MinByKey<P, F> as ParallelSink<Item>>::ReduceA, <MinByKey<P, F> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <MinByKey<P, F> as ParallelSink<Item>>::ReduceA, <MinByKey<P, F> as ParallelSink<Item>>::ReduceC)
impl<P, Item, ID, F, B> ParallelSink<Item> for Fold<P, ID, F, B> where
B: Send + 'static,
F: FnMut<(B, Either<<P as ParallelPipe<Item>>::Output, B>), Output = B> + Clone + Send + 'static,
ID: FnMut<(), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
[src]
B: Send + 'static,
F: FnMut<(B, Either<<P as ParallelPipe<Item>>::Output, B>), Output = B> + Clone + Send + 'static,
ID: FnMut<(), Output = B> + Clone + Send + 'static,
P: ParallelPipe<Item>,
type Done = <<Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceC as Reducer<<<Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done>>::Done
type Pipe = P
type ReduceA = FolderSyncReducer<<P as ParallelPipe<Item>>::Output, FoldFolder<<P as ParallelPipe<Item>>::Output, ID, F, B, StepA>>
type ReduceC = FolderSyncReducer<<<Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceA as Reducer<<P as ParallelPipe<Item>>::Output>>::Done, FoldFolder<<P as ParallelPipe<Item>>::Output, ID, F, B, StepB>>
fn reducers(
self
) -> (P, <Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceA, <Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (P, <Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceA, <Fold<P, ID, F, B> as ParallelSink<Item>>::ReduceC)
impl<P, Item, T> ParallelSink<Item> for Collect<P, T> where
P: ParallelPipe<Item>,
T: FromParallelStream<<P as ParallelPipe<Item>>::Output>,
[src]
P: ParallelPipe<Item>,
T: FromParallelStream<<P as ParallelPipe<Item>>::Output>,
type Done = T
type Pipe = P
type ReduceA = <T as FromParallelStream<<P as ParallelPipe<Item>>::Output>>::ReduceA
type ReduceC = <T as FromParallelStream<<P as ParallelPipe<Item>>::Output>>::ReduceC
fn reducers(
self
) -> (<Collect<P, T> as ParallelSink<Item>>::Pipe, <Collect<P, T> as ParallelSink<Item>>::ReduceA, <Collect<P, T> as ParallelSink<Item>>::ReduceC)
[src]
self
) -> (<Collect<P, T> as ParallelSink<Item>>::Pipe, <Collect<P, T> as ParallelSink<Item>>::ReduceA, <Collect<P, T> as ParallelSink<Item>>::ReduceC)