Struct AsyncConsIter

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

Async version of ConsIter.

Implementations

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

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 ConsIter::reset_index.

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

Async version of ConsIter::peek_ref.

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

Async version of ConsIter::peek_slice.

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

Async version of ConsIter::peek_available.

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

Async version of ConsIter::pop.

Safety

See above.

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

Async version of ConsIter::pop_move.

Safety

See above.

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

where T: Copy,

Async version of ConsIter::copy_item.

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

where T: Clone,

Async version of ConsIter::clone_item.

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

where T: Copy,

Async version of ConsIter::copy_slice.

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

where T: Clone,

Async version of ConsIter::clone_slice.

Trait Implementations

impl<'buf, B: MutRB<Item = T>, T, const W: bool> AsyncIterator for AsyncConsIter<'buf, B, W>

type I = ConsIter<'buf, B, W>

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, const W: bool> Send for AsyncConsIter<'buf, B, W>