[][src]Trait amadeus::par_pipe::PipeTask

#[must_use]pub trait PipeTask<Input> where
    <Self::Async as Pipe<Input>>::Output == Self::Output
{ type Output; type Async: Pipe<Input>; fn into_async(self) -> Self::Async; }

Associated Types

type Output

type Async: Pipe<Input>

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementations on Foreign Types

impl<Input, C0, C1> PipeTask<Input> for (C0, C1) where
    C0: PipeTask<Input>,
    C1: PipeTask<Input>,
    Input: Copy
[src]

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>

impl<Input, C0, C1, C2> PipeTask<Input> for (C0, C1, C2) where
    C0: PipeTask<Input>,
    C1: PipeTask<Input>,
    C2: PipeTask<Input>,
    Input: Copy
[src]

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>

impl<A, B, Input> PipeTask<Input> for Sum2<A, B> where
    A: PipeTask<Input>,
    B: PipeTask<Input, Output = <A as PipeTask<Input>>::Output>, 
[src]

type Output = <A as PipeTask<Input>>::Output

type Async = Sum2<<A as PipeTask<Input>>::Async, <B as PipeTask<Input>>::Async>

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]

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>

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]

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>

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]

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>

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]

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>

impl<Input, C0> PipeTask<Input> for (C0,) where
    C0: PipeTask<Input>, 
[src]

type Output = Sum1<<C0 as PipeTask<Input>>::Output>

type Async = AsyncTuple1<Input, <C0 as PipeTask<Input>>::Async>

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]

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>

impl<Input> PipeTask<Input> for ()[src]

type Output = Sum0

type Async = AsyncTuple0<Input>

Loading content...

Implementors

impl<'a, C, Input, T> PipeTask<&'a Input> for ClonedTask<C> where
    C: PipeTask<&'a Input, Output = &'a T>,
    T: 'a + Clone
[src]

type Output = T

type Async = ClonedTask<<C as PipeTask<&'a Input>>::Async>

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]

type Output = <C as PipeTask<Input>>::Output

type Async = Filter<<C as PipeTask<Input>>::Async, F>

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]

type Output = <C as PipeTask<Input>>::Output

type Async = InspectTask<<C as PipeTask<Input>>::Async, F>

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]

type Output = <C as PipeTask<Input>>::Output

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

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]

type Output = R

type Async = FilterMapSync<<C as PipeTask<Input>>::Async, F>

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]

type Output = <R as Iterator>::Item

type Async = FlatMapSync<<C as PipeTask<Input>>::Async, F, R>

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]

type Output = <R as Stream>::Item

type Async = FlatMap<<C as PipeTask<Input>>::Async, F, R>

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]

type Output = R

type Async = Map<<C as PipeTask<Input>>::Async, F>

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]

type Output = R

type Async = Map<<C as PipeTask<Input>>::Async, F>

impl<Item> PipeTask<Item> for IdentityTask[src]

type Output = Item

type Async = IdentityTask

Loading content...