Struct amadeus_core::pipe::PipeSink

pub struct PipeSink<P, S> { /* fields omitted */ }

Trait Implementations

impl<P, S> PinnedDrop for PipeSink<P, S>

unsafe fn drop(self: Pin<&mut Self>)

impl<P, S, Item> Sink<Item> for PipeSink<P, S> where
    P: Pipe<Item>,
    S: Sink<P::Output>, 

type Done = S::Done

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

Returns Poll::Ready when a) it can't accept any more elements from stream and b) all accepted elements have been fully processed. By convention, stream yielding None typically triggers (a).

fn send(&mut self, item: Item) -> Send<Self, Item>ⓘ

Important traits for Send<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item, '_> Future for Send<'_, S, Item> type Output = Option<S::Done>;

where
    Self: Unpin, 

fn send_all<'a, S: ?Sized>(
    &'a mut self,
    items: &'a mut S
) -> SendAll<'a, Self, S>ⓘ

Important traits for SendAll<'_, S, St>

impl<S: ?Sized + Sink<Item> + Unpin, St: ?Sized + Stream<Item = Item> + Unpin, Item, '_> Future for SendAll<'_, S, St> type Output = Option<S::Done>;

where
    S: Stream<Item = Item> + Unpin,
    Self: Unpin, 

fn done(&mut self) -> Done<Self, Item>ⓘ

Important traits for Done<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item, '_> Future for Done<'_, S, Item> type Output = S::Done;

where
    Self: Unpin, 

impl<'pin, P, S> Unpin for PipeSink<P, S> where
    __PipeSink<'pin, P, S>: Unpin, 

impl<P, S> UnsafeUnpin for PipeSink<P, S>