Struct AsyncWorkIter

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

Async version of WorkIter.

Implementations

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

pub fn get_workable<'b>(&mut self) -> MRBFuture<'_, Self, (), &'b mut T, true>

Async version of MRBIterator::get_workable.

pub fn get_workable_slice_exact<'b>( &mut self, count: usize, ) -> MRBFuture<'_, Self, usize, (&'b mut [T], &'b mut [T]), true>

Async version of MRBIterator::get_workable_slice_exact.

pub fn get_workable_slice_avail<'b>( &mut self, ) -> MRBFuture<'_, Self, (), (&'b mut [T], &'b mut [T]), true>

Async version of MRBIterator::get_workable_slice_avail.

pub fn get_workable_slice_multiple_of<'b>( &mut self, count: usize, ) -> MRBFuture<'_, Self, usize, (&'b mut [T], &'b mut [T]), true>

Async version of MRBIterator::get_workable_slice_multiple_of.

pub fn reset_index(&mut self)

Same as WorkIter::reset_index.

Trait Implementations

impl<'buf, B: MutRB<Item = T>, T> AsyncIterator for AsyncWorkIter<'buf, B>

type I = WorkIter<'buf, B>

type B = B

fn register_waker(&mut self, waker: &Waker)

fn inner(&self) -> &Self::I

fn inner_mut(&mut self) -> &mut Self::I

fn into_sync(self) -> Self::I

fn from_sync(iter: Self::I) -> Self

fn detach(self) -> AsyncDetached<Self, Self::B>

where Self: Sized,

fn is_prod_alive(&self) -> bool

Same as MRBIterator::is_prod_alive.

fn is_work_alive(&self) -> bool

Same as MRBIterator::is_work_alive.

fn is_cons_alive(&self) -> bool

Same as MRBIterator::is_cons_alive.

fn prod_index(&self) -> usize

Same as MRBIterator::prod_index.

fn work_index(&self) -> usize

Same as MRBIterator::work_index.

fn cons_index(&self) -> usize

Same as MRBIterator::cons_index.

fn index(&self) -> usize

Same as MRBIterator::index.

fn available(&mut self) -> usize

Same as MRBIterator::available.

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

Same as MRBIterator::advance.

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