Struct mutringbuf::iterators::async_iterators::cons_iter::AsyncConsIter

pub struct AsyncConsIter<B: MutRB, const W: bool> { /* private fields */ }

Async version of ConsIter.

Implementations

impl<B: MutRB<Item = T>, T, const W: bool> AsyncConsIter<B, W>

pub fn from_sync(iter: ConsIter<B, W>) -> Self

pub fn into_sync(self) -> ConsIter<B, W>

pub fn is_prod_alive(&self) -> bool

Same as ConsIter::is_prod_alive.

pub fn is_work_alive(&self) -> bool

Same as ConsIter::is_work_alive.

pub fn index(&self) -> usize

Same as ConsIter::index.

pub unsafe fn advance(&mut self, count: usize)

Same as ConsIter::advance.

Safety

Same as ConsIter::advance.

pub fn available(&mut self) -> usize

Same as ConsIter::available.

pub fn reset_index(&mut self)

Same as ConsIter::reset_index.

pub fn peek_ref(&mut self) -> PeekRefFuture<'_, B, T, W>

pub fn peek_slice(&mut self, count: usize) -> PeekSliceFuture<'_, B, T, W>

pub fn peek_available(&mut self) -> PeekAvailableFuture<'_, B, T, W>

pub unsafe fn pop(&mut self) -> PopFuture<'_, B, T, W>

Tries to pop an element, moving it.

Safety

Same as ConsIter::pop

pub fn copy_item<'b>( &mut self, dst: &'b mut T ) -> CopyItemFuture<'_, 'b, B, T, W>

where T: Copy,

pub fn clone_item<'b>( &mut self, dst: &'b mut T ) -> CloneItemFuture<'_, 'b, B, T, W>

where T: Clone,

pub fn copy_slice<'b>( &mut self, dst: &'b mut [T] ) -> CopySliceFuture<'_, 'b, B, T, W>

where T: Copy,

pub fn clone_slice<'b>( &mut self, dst: &'b mut [T] ) -> CloneSliceFuture<'_, 'b, B, T, W>

where T: Clone,

Trait Implementations

impl<B: ConcurrentRB + MutRB<Item = T>, T, const W: bool> Send for AsyncConsIter<B, W>