Type Alias async_ringbuf::wrap::AsyncCons
source · pub type AsyncCons<R> = AsyncWrap<R, false, true>;
Aliased Type§
struct AsyncCons<R> { /* private fields */ }
Trait Implementations§
source§impl<R: AsyncRbRef> AsyncConsumer for AsyncCons<R>
impl<R: AsyncRbRef> AsyncConsumer for AsyncCons<R>
fn register_waker(&self, waker: &Waker)
fn close(&mut self)
source§fn pop(&mut self) -> PopFuture<'_, Self> ⓘ
fn pop(&mut self) -> PopFuture<'_, Self> ⓘ
Pop item from the ring buffer waiting asynchronously if the buffer is empty. Read more
source§fn wait_occupied(&mut self, count: usize) -> WaitOccupiedFuture<'_, Self> ⓘ
fn wait_occupied(&mut self, count: usize) -> WaitOccupiedFuture<'_, Self> ⓘ
Wait for the buffer to contain at least
count
items or to close. Read more