Trait amadeus_core::sink::Sink

pub trait Sink {
    type Item;
    fn poll_forward(
        self: Pin<&mut Self>, 
        cx: &mut Context, 
        stream: Pin<&mut impl Stream<Item = Self::Item>>
    ) -> Poll<()>;
}

Associated Types

type Item

Loading content...

Required methods

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

Loading content...

Implementations on Foreign Types

impl<P> Sink for Pin<P> where
    P: DerefMut + Unpin,
    P::Target: Sink, 

type Item = <P::Target as Sink>::Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

impl<'_, T: ?Sized> Sink for &'_ mut T where
    T: Sink + Unpin, 

type Item = T::Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

Loading content...

Implementors

impl<'a, F, I, Fut, Item> Sink for SinkFilter<'a, F, I, Item, Fut> where
    F: FnMut(&Item) -> Fut,
    Fut: Future<Output = bool>,
    I: Sink<Item = Item>, 

type Item = Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

impl<'a, F, I, R, Fut, Item> Sink for SinkFlatMap<'a, F, I, Fut, R, Item> where
    F: FnMut(Item) -> Fut,
    Fut: Stream<Item = R>,
    I: Sink<Item = R>, 

type Item = Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

impl<'a, F, I, R, Fut, Item> Sink for SinkThen<'a, F, I, Fut, R, Item> where
    F: FnMut(Item) -> Fut,
    Fut: Future<Output = R>,
    I: Sink<Item = R>, 

type Item = Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

impl<F, I, R, Item> Sink for SinkMap<F, I, R, Item> where
    F: FnMut(Item) -> R,
    I: Sink<Item = R>, 

type Item = Item

fn poll_forward(
    self: Pin<&mut Self>,
    cx: &mut Context,
    stream: Pin<&mut impl Stream<Item = Self::Item>>
) -> Poll<()>

Loading content...