[−][src]Trait amadeus::par_pipe::PipeTaskAsync
Associated Types
type Item
Required methods
fn poll_run(
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
self: Pin<&mut Self>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = Self::Item>>
) -> Poll<()>
Implementations on Foreign Types
impl<'_, T, Source> PipeTaskAsync<Source> for &'_ mut T where
T: PipeTaskAsync<Source> + Unpin + ?Sized,
[src]
T: PipeTaskAsync<Source> + Unpin + ?Sized,
type Item = <T as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut &'_ mut T>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <&'_ mut T as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut &'_ mut T>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <&'_ mut T as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<A, B, Source> PipeTaskAsync<Source> for Sum2<A, B> where
A: PipeTaskAsync<Source>,
B: PipeTaskAsync<Source, Item = <A as PipeTaskAsync<Source>>::Item>,
[src]
A: PipeTaskAsync<Source>,
B: PipeTaskAsync<Source, Item = <A as PipeTaskAsync<Source>>::Item>,
type Item = <A as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut Sum2<A, B>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <Sum2<A, B> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Sum2<A, B>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <Sum2<A, B> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<P, Source> PipeTaskAsync<Source> for Pin<P> where
P: DerefMut + Unpin,
<P as Deref>::Target: PipeTaskAsync<Source>,
[src]
P: DerefMut + Unpin,
<P as Deref>::Target: PipeTaskAsync<Source>,
type Item = <<P as Deref>::Target as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut Pin<P>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <Pin<P> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut Pin<P>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <Pin<P> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
Implementors
impl<'a, C, Source, T> PipeTaskAsync<&'a Source> for ClonedTask<C> where
C: PipeTaskAsync<&'a Source, Item = &'a T>,
Source: 'a,
T: 'a + Clone,
[src]
C: PipeTaskAsync<&'a Source, Item = &'a T>,
Source: 'a,
T: 'a + Clone,
type Item = T
fn poll_run(
self: Pin<&mut ClonedTask<C>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = &'a Source>>,
sink: Pin<&mut impl Sink<Item = <ClonedTask<C> as PipeTaskAsync<&'a Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut ClonedTask<C>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = &'a Source>>,
sink: Pin<&mut impl Sink<Item = <ClonedTask<C> as PipeTaskAsync<&'a Source>>::Item>>
) -> Poll<()>
impl<A, B, Source> PipeTaskAsync<Source> for JoinTask<A, B> where
A: PipeTaskAsync<Source>,
B: PipeTaskAsync<<A as PipeTaskAsync<Source>>::Item>,
[src]
A: PipeTaskAsync<Source>,
B: PipeTaskAsync<<A as PipeTaskAsync<Source>>::Item>,
type Item = <B as PipeTaskAsync<<A as PipeTaskAsync<Source>>::Item>>::Item
fn poll_run(
self: Pin<&mut JoinTask<A, B>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <JoinTask<A, B> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut JoinTask<A, B>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <JoinTask<A, B> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<C, F, Fut, Source> PipeTaskAsync<Source> for FilterStreamTaskAsync<C, F, <C as PipeTaskAsync<Source>>::Item, Fut> where
C: PipeTaskAsync<Source>,
F: FnMut(&<C as PipeTaskAsync<Source>>::Item) -> Fut + Clone,
Fut: Future<Output = bool>,
[src]
C: PipeTaskAsync<Source>,
F: FnMut(&<C as PipeTaskAsync<Source>>::Item) -> Fut + Clone,
Fut: Future<Output = bool>,
type Item = <C as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut FilterStreamTaskAsync<C, F, <C as PipeTaskAsync<Source>>::Item, Fut>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <FilterStreamTaskAsync<C, F, <C as PipeTaskAsync<Source>>::Item, Fut> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut FilterStreamTaskAsync<C, F, <C as PipeTaskAsync<Source>>::Item, Fut>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <FilterStreamTaskAsync<C, F, <C as PipeTaskAsync<Source>>::Item, Fut> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<C, F, R, Source> PipeTaskAsync<Source> for FlatMapStreamTaskAsync<C, F, R> where
C: PipeTaskAsync<Source>,
F: FnMut(<C as PipeTaskAsync<Source>>::Item) -> R + Clone,
R: Stream,
[src]
C: PipeTaskAsync<Source>,
F: FnMut(<C as PipeTaskAsync<Source>>::Item) -> R + Clone,
R: Stream,
type Item = <R as Stream>::Item
fn poll_run(
self: Pin<&mut FlatMapStreamTaskAsync<C, F, R>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <FlatMapStreamTaskAsync<C, F, R> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut FlatMapStreamTaskAsync<C, F, R>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <FlatMapStreamTaskAsync<C, F, R> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<C, F, R, Source> PipeTaskAsync<Source> for MapTask<C, F> where
C: PipeTaskAsync<Source>,
F: FnMut(<C as PipeTaskAsync<Source>>::Item) -> R + Clone,
[src]
C: PipeTaskAsync<Source>,
F: FnMut(<C as PipeTaskAsync<Source>>::Item) -> R + Clone,
type Item = R
fn poll_run(
self: Pin<&mut MapTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <MapTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut MapTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <MapTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<C, F, Source> PipeTaskAsync<Source> for InspectTask<C, F> where
C: PipeTaskAsync<Source>,
F: FnMut(&<C as PipeTaskAsync<Source>>::Item) + Clone,
[src]
C: PipeTaskAsync<Source>,
F: FnMut(&<C as PipeTaskAsync<Source>>::Item) + Clone,
type Item = <C as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut InspectTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <InspectTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut InspectTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <InspectTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<C, F, Source> PipeTaskAsync<Source> for UpdateTask<C, F> where
C: PipeTaskAsync<Source>,
F: FnMut(&mut <C as PipeTaskAsync<Source>>::Item) + Clone,
[src]
C: PipeTaskAsync<Source>,
F: FnMut(&mut <C as PipeTaskAsync<Source>>::Item) + Clone,
type Item = <C as PipeTaskAsync<Source>>::Item
fn poll_run(
self: Pin<&mut UpdateTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <UpdateTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut UpdateTask<C, F>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <UpdateTask<C, F> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Item> PipeTaskAsync<Item> for IdentityTask
[src]
type Item = Item
fn poll_run(
self: Pin<&mut IdentityTask>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Item>>,
sink: Pin<&mut impl Sink<Item = <IdentityTask as PipeTaskAsync<Item>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut IdentityTask>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Item>>,
sink: Pin<&mut impl Sink<Item = <IdentityTask as PipeTaskAsync<Item>>::Item>>
) -> Poll<()>
impl<Source> PipeTaskAsync<Source> for AsyncTuple0<Source>
[src]
type Item = Sum0
fn poll_run(
self: Pin<&mut AsyncTuple0<Source>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple0<Source> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple0<Source>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple0<Source> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0> PipeTaskAsync<Source> for AsyncTuple1<Source, C0> where
C0: PipeTaskAsync<Source>,
[src]
C0: PipeTaskAsync<Source>,
type Item = Sum1<<C0 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple1<Source, C0>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple1<Source, C0> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple1<Source, C0>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple1<Source, C0> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1> PipeTaskAsync<Source> for AsyncTuple2<Source, C0, C1> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum2<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple2<Source, C0, C1>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple2<Source, C0, C1> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple2<Source, C0, C1>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple2<Source, C0, C1> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2> PipeTaskAsync<Source> for AsyncTuple3<Source, C0, C1, C2> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum3<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple3<Source, C0, C1, C2>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple3<Source, C0, C1, C2> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple3<Source, C0, C1, C2>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple3<Source, C0, C1, C2> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2, C3> PipeTaskAsync<Source> for AsyncTuple4<Source, C0, C1, C2, C3> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum4<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item, <C3 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple4<Source, C0, C1, C2, C3>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple4<Source, C0, C1, C2, C3> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple4<Source, C0, C1, C2, C3>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple4<Source, C0, C1, C2, C3> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2, C3, C4> PipeTaskAsync<Source> for AsyncTuple5<Source, C0, C1, C2, C3, C4> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum5<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item, <C3 as PipeTaskAsync<Source>>::Item, <C4 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple5<Source, C0, C1, C2, C3, C4>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple5<Source, C0, C1, C2, C3, C4> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple5<Source, C0, C1, C2, C3, C4>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple5<Source, C0, C1, C2, C3, C4> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2, C3, C4, C5> PipeTaskAsync<Source> for AsyncTuple6<Source, C0, C1, C2, C3, C4, C5> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum6<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item, <C3 as PipeTaskAsync<Source>>::Item, <C4 as PipeTaskAsync<Source>>::Item, <C5 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple6<Source, C0, C1, C2, C3, C4, C5>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple6<Source, C0, C1, C2, C3, C4, C5> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple6<Source, C0, C1, C2, C3, C4, C5>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple6<Source, C0, C1, C2, C3, C4, C5> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2, C3, C4, C5, C6> PipeTaskAsync<Source> for AsyncTuple7<Source, C0, C1, C2, C3, C4, C5, C6> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
C6: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
C6: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum7<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item, <C3 as PipeTaskAsync<Source>>::Item, <C4 as PipeTaskAsync<Source>>::Item, <C5 as PipeTaskAsync<Source>>::Item, <C6 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple7<Source, C0, C1, C2, C3, C4, C5, C6>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple7<Source, C0, C1, C2, C3, C4, C5, C6> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple7<Source, C0, C1, C2, C3, C4, C5, C6>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple7<Source, C0, C1, C2, C3, C4, C5, C6> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
impl<Source, C0, C1, C2, C3, C4, C5, C6, C7> PipeTaskAsync<Source> for AsyncTuple8<Source, C0, C1, C2, C3, C4, C5, C6, C7> where
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
C6: PipeTaskAsync<Source>,
C7: PipeTaskAsync<Source>,
Source: Copy,
[src]
C0: PipeTaskAsync<Source>,
C1: PipeTaskAsync<Source>,
C2: PipeTaskAsync<Source>,
C3: PipeTaskAsync<Source>,
C4: PipeTaskAsync<Source>,
C5: PipeTaskAsync<Source>,
C6: PipeTaskAsync<Source>,
C7: PipeTaskAsync<Source>,
Source: Copy,
type Item = Sum8<<C0 as PipeTaskAsync<Source>>::Item, <C1 as PipeTaskAsync<Source>>::Item, <C2 as PipeTaskAsync<Source>>::Item, <C3 as PipeTaskAsync<Source>>::Item, <C4 as PipeTaskAsync<Source>>::Item, <C5 as PipeTaskAsync<Source>>::Item, <C6 as PipeTaskAsync<Source>>::Item, <C7 as PipeTaskAsync<Source>>::Item>
fn poll_run(
self: Pin<&mut AsyncTuple8<Source, C0, C1, C2, C3, C4, C5, C6, C7>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple8<Source, C0, C1, C2, C3, C4, C5, C6, C7> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>
[src]
self: Pin<&mut AsyncTuple8<Source, C0, C1, C2, C3, C4, C5, C6, C7>>,
cx: &mut Context,
stream: Pin<&mut impl Stream<Item = Source>>,
sink: Pin<&mut impl Sink<Item = <AsyncTuple8<Source, C0, C1, C2, C3, C4, C5, C6, C7> as PipeTaskAsync<Source>>::Item>>
) -> Poll<()>