Struct mutringbuf::iterators::async_iterators::work_iter::AsyncWorkIter

pub struct AsyncWorkIter<B: MutRB> { /* private fields */ }

Async version of WorkIter.

Implementations

impl<B: MutRB<Item = T>, T> AsyncWorkIter<B>

pub fn from_sync(iter: WorkIter<B>) -> Self

pub fn into_sync(self) -> WorkIter<B>

pub fn is_prod_alive(&self) -> bool

Same as WorkIter::is_prod_alive.

pub fn is_cons_alive(&self) -> bool

Same as WorkIter::is_cons_alive.

pub fn index(&self) -> usize

Same as WorkIter::index.

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

Same as WorkIter::advance.

Safety

Same as WorkIter::advance.

pub fn available(&mut self) -> usize

Same as WorkIter::available.

pub fn reset_index(&mut self)

Same as WorkIter::reset_index.

pub fn detach(self) -> AsyncDetachedWorkIter<B>

Detaches the iterator yielding a DetachedWorkIter.

pub fn get_workable(&mut self) -> GetWorkableFuture<'_, B, T>

Returns a mutable references to the current value.

Being these references, Self::advance() has to be called when done with the mutation in order to move the iterator.

pub fn get_workable_slice_exact( &mut self, count: usize ) -> GetWorkableSliceExactFuture<'_, B, T>

Returns a tuple of mutable slice references, the sum of which with len equal to count.

Being these references, Self::advance() has to be called when done with the mutation in order to move the iterator.

pub fn get_workable_slice_avail( &mut self ) -> GetWorkableSliceAvailFuture<'_, B, T>

Returns a tuple of mutable slice references, the sum of which with len equal to Self::available().

Being these references, Self::advance() has to be called when done with the mutation in order to move the iterator.

pub fn get_workable_slice_multiple_of( &mut self, rhs: usize ) -> GetWorkableSliceMultipleOfFuture<'_, B, T>

Returns a tuple of mutable slice references, the sum of which with len equal to the maximum multiple of modulo.

Being these references, Self::advance() has to be called when done with the mutation in order to move the iterator.

Trait Implementations

impl<B: ConcurrentRB + MutRB<Item = T>, T> Send for AsyncWorkIter<B>