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