Trait amadeus_core::dist_stream::StreamTaskAsync

#[must_use]pub trait StreamTaskAsync {
    type Item;
    fn poll_run(
        self: Pin<&mut Self>, 
        cx: &mut Context, 
        sink: Pin<&mut impl Sink<Self::Item>>
    ) -> Poll<()>;
}

Associated Types

type Item

Loading content...

Required methods

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

Loading content...

Implementations on Foreign Types

impl<A: StreamTaskAsync, B: StreamTaskAsync<Item = A::Item>> StreamTaskAsync for Sum2<A, B>

type Item = A::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

Loading content...

Implementors

impl StreamTaskAsync for Never

type Item = Self

fn poll_run(
    self: Pin<&mut Self>,
    _cx: &mut Context,
    _sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<A: StreamTaskAsync, B: StreamTaskAsync<Item = A::Item>> StreamTaskAsync for ChainTask<A, B>

type Item = A::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<C: StreamTaskAsync, F> StreamTaskAsync for InspectTask<C, F> where
    F: FnMut(&C::Item) + Clone, 

type Item = C::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

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

type Item = C::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<C: StreamTaskAsync, F, Fut> StreamTaskAsync for FilterStreamTaskAsync<C, F, C::Item, Fut> where
    F: FnMut(&C::Item) -> Fut + Clone,
    Fut: Future<Output = bool>, 

type Item = C::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<C: StreamTaskAsync, F, R> StreamTaskAsync for MapTask<C, F> where
    F: FnMut(C::Item) -> R + Clone, 

type Item = R

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<C: StreamTaskAsync, F: FnMut(C::Item) -> R + Clone, R: Stream> StreamTaskAsync for FlatMapStreamTaskAsync<C, F, R>

type Item = R::Item

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

impl<T> StreamTaskAsync for IterIterTask<T>

type Item = T

fn poll_run(
    self: Pin<&mut Self>,
    cx: &mut Context,
    sink: Pin<&mut impl Sink<Self::Item>>
) -> Poll<()>

Loading content...