[−][src]Trait amadeus::par_pipe::PipeTask
Associated Types
Loading content...Required methods
fn into_async(self) -> Self::Async
Implementations on Foreign Types
impl<Input, C0, C1> PipeTask<Input> for (C0, C1) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
Input: Copy,
type Output = Sum2<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output>
type Async = AsyncTuple2<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1) as PipeTask<Input>>::Async
[src]
impl<Input, C0, C1, C2> PipeTask<Input> for (C0, C1, C2) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
Input: Copy,
type Output = Sum3<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output>
type Async = AsyncTuple3<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1, C2) as PipeTask<Input>>::Async
[src]
impl<A, B, Input> PipeTask<Input> for Sum2<A, B> where
A: PipeTask<Input>,
B: PipeTask<Input, Output = <A as PipeTask<Input>>::Output>,
[src]
A: PipeTask<Input>,
B: PipeTask<Input, Output = <A as PipeTask<Input>>::Output>,
type Output = <A as PipeTask<Input>>::Output
type Async = Sum2<<A as PipeTask<Input>>::Async, <B as PipeTask<Input>>::Async>
fn into_async(self) -> <Sum2<A, B> as PipeTask<Input>>::Async
[src]
impl<Input, C0, C1, C2, C3> PipeTask<Input> for (C0, C1, C2, C3) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
Input: Copy,
type Output = Sum4<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output, <C3 as PipeTask<Input>>::Output>
type Async = AsyncTuple4<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async, <C3 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1, C2, C3) as PipeTask<Input>>::Async
[src]
impl<Input, C0, C1, C2, C3, C4, C5, C6> PipeTask<Input> for (C0, C1, C2, C3, C4, C5, C6) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
C6: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
C6: PipeTask<Input>,
Input: Copy,
type Output = Sum7<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output, <C3 as PipeTask<Input>>::Output, <C4 as PipeTask<Input>>::Output, <C5 as PipeTask<Input>>::Output, <C6 as PipeTask<Input>>::Output>
type Async = AsyncTuple7<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async, <C3 as PipeTask<Input>>::Async, <C4 as PipeTask<Input>>::Async, <C5 as PipeTask<Input>>::Async, <C6 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1, C2, C3, C4, C5, C6) as PipeTask<Input>>::Async
[src]
impl<Input, C0, C1, C2, C3, C4, C5, C6, C7> PipeTask<Input> for (C0, C1, C2, C3, C4, C5, C6, C7) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
C6: PipeTask<Input>,
C7: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
C6: PipeTask<Input>,
C7: PipeTask<Input>,
Input: Copy,
type Output = Sum8<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output, <C3 as PipeTask<Input>>::Output, <C4 as PipeTask<Input>>::Output, <C5 as PipeTask<Input>>::Output, <C6 as PipeTask<Input>>::Output, <C7 as PipeTask<Input>>::Output>
type Async = AsyncTuple8<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async, <C3 as PipeTask<Input>>::Async, <C4 as PipeTask<Input>>::Async, <C5 as PipeTask<Input>>::Async, <C6 as PipeTask<Input>>::Async, <C7 as PipeTask<Input>>::Async>
fn into_async(
self
) -> <(C0, C1, C2, C3, C4, C5, C6, C7) as PipeTask<Input>>::Async
[src]
self
) -> <(C0, C1, C2, C3, C4, C5, C6, C7) as PipeTask<Input>>::Async
impl<Input, C0, C1, C2, C3, C4, C5> PipeTask<Input> for (C0, C1, C2, C3, C4, C5) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
C5: PipeTask<Input>,
Input: Copy,
type Output = Sum6<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output, <C3 as PipeTask<Input>>::Output, <C4 as PipeTask<Input>>::Output, <C5 as PipeTask<Input>>::Output>
type Async = AsyncTuple6<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async, <C3 as PipeTask<Input>>::Async, <C4 as PipeTask<Input>>::Async, <C5 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1, C2, C3, C4, C5) as PipeTask<Input>>::Async
[src]
impl<Input, C0> PipeTask<Input> for (C0,) where
C0: PipeTask<Input>,
[src]
C0: PipeTask<Input>,
type Output = Sum1<<C0 as PipeTask<Input>>::Output>
type Async = AsyncTuple1<Input, <C0 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0,) as PipeTask<Input>>::Async
[src]
impl<Input, C0, C1, C2, C3, C4> PipeTask<Input> for (C0, C1, C2, C3, C4) where
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
Input: Copy,
[src]
C0: PipeTask<Input>,
C1: PipeTask<Input>,
C2: PipeTask<Input>,
C3: PipeTask<Input>,
C4: PipeTask<Input>,
Input: Copy,
type Output = Sum5<<C0 as PipeTask<Input>>::Output, <C1 as PipeTask<Input>>::Output, <C2 as PipeTask<Input>>::Output, <C3 as PipeTask<Input>>::Output, <C4 as PipeTask<Input>>::Output>
type Async = AsyncTuple5<Input, <C0 as PipeTask<Input>>::Async, <C1 as PipeTask<Input>>::Async, <C2 as PipeTask<Input>>::Async, <C3 as PipeTask<Input>>::Async, <C4 as PipeTask<Input>>::Async>
fn into_async(self) -> <(C0, C1, C2, C3, C4) as PipeTask<Input>>::Async
[src]
impl<Input> PipeTask<Input> for ()
[src]
type Output = Sum0
type Async = AsyncTuple0<Input>
fn into_async(self) -> <() as PipeTask<Input>>::Async
[src]
Implementors
impl<'a, C, Input, T> PipeTask<&'a Input> for ClonedTask<C> where
C: PipeTask<&'a Input, Output = &'a T>,
T: 'a + Clone,
[src]
C: PipeTask<&'a Input, Output = &'a T>,
T: 'a + Clone,
type Output = T
type Async = ClonedTask<<C as PipeTask<&'a Input>>::Async>
fn into_async(self) -> <ClonedTask<C> as PipeTask<&'a Input>>::Async
[src]
impl<C, F, Input> PipeTask<Input> for FilterTask<C, F> where
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a <C as PipeTask<Input>>::Output,), Output = bool>,
[src]
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a <C as PipeTask<Input>>::Output,), Output = bool>,
type Output = <C as PipeTask<Input>>::Output
type Async = Filter<<C as PipeTask<Input>>::Async, F>
fn into_async(self) -> <FilterTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, Input> PipeTask<Input> for InspectTask<C, F> where
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a <C as PipeTask<Input>>::Output,), Output = ()> + Clone,
[src]
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a <C as PipeTask<Input>>::Output,), Output = ()> + Clone,
type Output = <C as PipeTask<Input>>::Output
type Async = InspectTask<<C as PipeTask<Input>>::Async, F>
fn into_async(self) -> <InspectTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, Input> PipeTask<Input> for UpdateTask<C, F> where
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a mut <C as PipeTask<Input>>::Output,), Output = ()> + Clone,
[src]
C: PipeTask<Input>,
F: for<'a> FnMut<(&'a mut <C as PipeTask<Input>>::Output,), Output = ()> + Clone,
type Output = <C as PipeTask<Input>>::Output
type Async = UpdateTask<<C as PipeTask<Input>>::Async, F>
fn into_async(self) -> <UpdateTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, R, Input> PipeTask<Input> for FilterMapSyncTask<C, F> where
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = Option<R>> + Clone,
[src]
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = Option<R>> + Clone,
type Output = R
type Async = FilterMapSync<<C as PipeTask<Input>>::Async, F>
fn into_async(self) -> <FilterMapSyncTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, R, Input> PipeTask<Input> for FlatMapSyncTask<C, F> where
C: PipeTask<Input>,
F: Clone + FnMut<(<C as PipeTask<Input>>::Output,), Output = R>,
R: Iterator,
[src]
C: PipeTask<Input>,
F: Clone + FnMut<(<C as PipeTask<Input>>::Output,), Output = R>,
R: Iterator,
type Output = <R as Iterator>::Item
type Async = FlatMapSync<<C as PipeTask<Input>>::Async, F, R>
fn into_async(self) -> <FlatMapSyncTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, R, Input> PipeTask<Input> for FlatMapTask<C, F> where
C: PipeTask<Input>,
F: Clone + FnMut<(<C as PipeTask<Input>>::Output,), Output = R>,
R: Stream,
[src]
C: PipeTask<Input>,
F: Clone + FnMut<(<C as PipeTask<Input>>::Output,), Output = R>,
R: Stream,
type Output = <R as Stream>::Item
type Async = FlatMap<<C as PipeTask<Input>>::Async, F, R>
fn into_async(self) -> <FlatMapTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, R, Input> PipeTask<Input> for MapSyncTask<C, F> where
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = R> + Clone,
[src]
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = R> + Clone,
type Output = R
type Async = Map<<C as PipeTask<Input>>::Async, F>
fn into_async(self) -> <MapSyncTask<C, F> as PipeTask<Input>>::Async
[src]
impl<C, F, R, Input> PipeTask<Input> for MapTask<C, F> where
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = R> + Clone,
[src]
C: PipeTask<Input>,
F: FnMut<(<C as PipeTask<Input>>::Output,), Output = R> + Clone,