Type Alias AsyncCons 

pub type AsyncCons<R> = AsyncWrap<R, false, true>;

Aliased Type

pub struct AsyncCons<R> { /* private fields */ }

Trait Implementations

impl<R: AsyncRbRef> AsyncConsumer for AsyncCons<R>

fn register_waker(&self, waker: &Waker)

fn close(&mut self)

fn is_closed(&self) -> bool

Whether the corresponding producer was closed.

fn pop(&mut self) -> PopFuture<'_, Self>

Pop item from the ring buffer waiting asynchronously if the buffer is empty.

fn wait_occupied(&mut self, count: usize) -> WaitOccupiedFuture<'_, Self>

Wait for the buffer to contain at least count items or to close.

fn pop_exact<'a: 'b, 'b>( &'a mut self, slice: &'b mut [Self::Item], ) -> PopSliceFuture<'a, 'b, Self>

where Self::Item: Copy,

Fill slice with items from the ring buffer waiting asynchronously until slice filled or corresponding producer closed.

fn pop_until_end<'a: 'b, 'b>( &'a mut self, vec: &'b mut Vec<Self::Item>, ) -> PopVecFuture<'a, 'b, Self>

Fill vec with items from the ring buffer waiting asynchronously until corresponding producer closed.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

where Self: Unpin,

Poll for the next item in the ring buffer.

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

where Self: AsyncConsumer<Item = u8> + Unpin,

Poll reading bytes from byte buffer.

impl<R: AsyncRbRef> AsyncRead for AsyncCons<R>

where Self: AsyncConsumer<Item = u8>,

Available on crate feature std only.

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<R: AsyncRbRef> Stream for AsyncCons<R>

type Item = <<R as RbRef>::Rb as Observer>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<R: AsyncRbRef> DelegateConsumer for AsyncCons<R>