Struct amadeus_core::pipe::PipeSink[−][src]

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

Trait Implementations

impl<P, S> PinnedDrop for PipeSink<P, S>[src]

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

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

type Done = S::Done

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

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). Read more

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

Notable 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, [src]

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

Notable 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, [src]

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

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

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

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

impl<P, S> UnsafeUnpin for PipeSink<P, S>[src]

Auto Trait Implementations

impl<P, S> RefUnwindSafe for PipeSink<P, S> where
    P: RefUnwindSafe,
    S: RefUnwindSafe, 

impl<P, S> Send for PipeSink<P, S> where
    P: Send,
    S: Send, 

impl<P, S> Sync for PipeSink<P, S> where
    P: Sync,
    S: Sync, 

impl<P, S> UnwindSafe for PipeSink<P, S> where
    P: UnwindSafe,
    S: UnwindSafe, 

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

Mutably borrows from an owned value. Read more

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

Performs the conversion.

impl<T, U> Into<U> for T where
    U: From<T>, [src]

pub fn into(self) -> U[src]

Performs the conversion.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

Performs the conversion.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

Performs the conversion.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

pub fn vzip(self) -> V