Struct AsyncProdIter

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

Async version of ProdIter.

Implementations

impl<'buf, B: MutRB<Item = T>, T> AsyncProdIter<'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 push(&mut self, item: T) -> MRBFuture<'_, Self, T, (), false>

Async version of ProdIter::push.

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

where T: Copy,

Async version of ProdIter::push_slice.

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

where T: Clone,

Async version of ProdIter::push_slice_clone.

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

Async version of ProdIter::get_next_item_mut.

Safety

Same as ProdIter::get_next_item_mut.

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

Async version of ProdIter::get_next_item_mut_init.

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

Async version of ProdIter::get_next_slices_mut.

Safety

See above.

Trait Implementations

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

type I = ProdIter<'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 AsyncProdIter<'buf, B>