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