Trait amadeus::par_pipe::PipeTask

#[must_use]pub trait PipeTask<Source> where
    <Self::Async as PipeTaskAsync<Source>>::Item == Self::Item, {
    type Item;
    type Async: PipeTaskAsync<Source>;
    fn into_async(self) -> Self::Async;
}

Associated Types

type Item

type Async: PipeTaskAsync<Source>

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementations on Foreign Types

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, 

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

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, 

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

impl<Source> PipeTask<Source> for ()

type Item = Sum0

type Async = AsyncTuple0<Source>

fn into_async(self) -> <() as PipeTask<Source>>::Async

impl<Source, C0, C1> PipeTask<Source> for (C0, C1) where
    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

impl<Source, C0> PipeTask<Source> for (C0,) where
    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

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, 

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

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, 

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

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, 

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

impl<Source, C0, C1, C2> PipeTask<Source> for (C0, C1, C2) where
    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

impl<A, B, Source> PipeTask<Source> for Sum2<A, B> where
    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

Loading content...

Implementors

impl<'a, C, Source, T> PipeTask<&'a Source> for ClonedTask<C> where
    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

impl<A, B, Source> PipeTask<Source> for JoinTask<A, B> where
    A: PipeTask<Source>,
    B: PipeTask<<A as PipeTask<Source>>::Item>, 

type Item = <B as PipeTask<<A as PipeTask<Source>>::Item>>::Item

type Async = JoinTask<<A as PipeTask<Source>>::Async, <B as PipeTask<<A as PipeTask<Source>>::Item>>::Async>

fn into_async(self) -> <JoinTask<A, B> as PipeTask<Source>>::Async

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>, 

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

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, 

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

impl<C, F, R, Source> PipeTask<Source> for MapTask<C, F> where
    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

impl<C, F, Source> PipeTask<Source> for InspectTask<C, F> where
    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

impl<C, F, Source> PipeTask<Source> for UpdateTask<C, F> where
    C: PipeTask<Source>,
    F: FnMut(&mut <C as PipeTask<Source>>::Item) + Clone, 

type Item = <C as PipeTask<Source>>::Item

type Async = UpdateTask<<C as PipeTask<Source>>::Async, F>

fn into_async(self) -> <UpdateTask<C, F> as PipeTask<Source>>::Async

impl<Item> PipeTask<Item> for IdentityTask

type Item = Item

type Async = IdentityTask

fn into_async(self) -> <IdentityTask as PipeTask<Item>>::Async

Loading content...