Struct mutringbuf::iterators::async_iterators::prod_iter::AsyncProdIter

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

Async version of ProdIter.

Implementations

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

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

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

pub fn is_work_alive(&self) -> bool

Same as ProdIter::is_work_alive.

pub fn is_cons_alive(&self) -> bool

Same as ProdIter::is_cons_alive.

pub fn index(&self) -> usize

Same as ProdIter::index.

pub fn available(&mut self) -> usize

Same as ProdIter::available.

pub fn push(&mut self, value: T) -> PushFuture<'_, B, T>

Async version of ProdIter::push.

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

where T: Copy,

Async version of ProdIter::push_slice.

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

where T: Clone,

Async version of ProdIter::push_slice_clone.

pub unsafe fn get_next_item_mut(&mut self) -> GetNextItemMutFuture<'_, B, T>

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) -> GetNextItemMutInitFuture<'_, B, T>

Async version of ProdIter::get_next_item_mut_init.

Trait Implementations

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