Struct ConsIter 

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

Iterator used to pop data from the buffer.

When working with types which implement both Copy and Clone traits, copy methods should be preferred over clone methods.

Implementations

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

pub fn reset_index(&mut self)

Resets the index of the iterator. I.e., moves the iterator to the location occupied by its successor.

pub fn peek_ref<'a>(&mut self) -> Option<&'a T>

Returns a reference to an element.

Being this a reference, Self::advance() has to be called when done with the data in order to move the iterator.

pub fn peek_slice<'a>(&mut self, count: usize) -> Option<NonMutableSlice<'a, T>>

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

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

pub fn peek_available<'a>(&mut self) -> Option<NonMutableSlice<'a, T>>

Returns a tuple of slice references, the sum of which with len equal to available data.

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

pub unsafe fn pop_move(&mut self) -> Option<T>

Tries to pop an element, moving it.

Safety

This method moves items, so locations from which they are moved out are left uninitialised. These locations must be re-initialised used proper ProdIter methods (*_init) ones

pub fn pop(&mut self) -> Option<T>

Tries to pop an element, duplicating it.

Safety

This method acts like ptr::read: it duplicates the item by making a bitwise copy, ignoring whether it is Copy/Clone or not. So it is your responsibility to ensure that the data may indeed be duplicated.

pub fn copy_item(&mut self, dst: &mut T) -> Option<()>

where T: Copy,

• Returns Some(()), copying next item into dst, if available.
• Returns None doing nothing, otherwise.

This method uses copy and should be preferred over clone version, if possible.

Unlike peek* methods, this one automatically advances the iterator.

pub fn clone_item(&mut self, dst: &mut T) -> Option<()>

where T: Clone,

Same as Self::copy_item, but uses clone, instead.

Unlike peek* methods, this one automatically advances the iterator.

pub fn copy_slice(&mut self, dst: &mut [T]) -> Option<()>

where T: Copy,

• Returns Some(()), filling dst slice with the next dst.len() values, if available.
• Returns None doing nothing, otherwise.

This method fills the slice using copy and should be preferred over clone version, if possible.

Unlike peek* methods, this one automatically advances the iterator.

pub fn clone_slice(&mut self, dst: &mut [T]) -> Option<()>

where T: Clone,

Same as Self::copy_slice, but uses clone, instead.

Unlike peek* methods, this one automatically advances the iterator.

Trait Implementations

impl<B: MutRB + IterManager, const W: bool> Drop for ConsIter<'_, B, W>

fn drop(&mut self)

Executes the destructor for this type.

impl<B: MutRB<Item = T>, T, const W: bool> MRBIterator for ConsIter<'_, B, W>

type Item = T

fn detach(self) -> Detached<Self>

where Self: Sized,

Detaches the iterator yielding a Detached.

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

Advances the iterator by count.

fn available(&mut self) -> usize

Returns the number of items available for an iterator.

fn wait_for(&mut self, count: usize)

Waits, blocking the thread in a loop, until there are at least count available items.

fn index(&self) -> usize

Returns the index of the iterator.

fn buf_len(&self) -> usize

Returns the length of the buffer.

fn alive_iters(&self) -> u8

Returns how many iterators are still alive.

fn prod_index(&self) -> usize

Returns the index of the producer.

fn work_index(&self) -> usize

Returns the index of the worker.

fn cons_index(&self) -> usize

Returns the index of the consumer.

fn get_workable<'a>(&mut self) -> Option<&'a mut Self::Item>

Returns a mutable references to the current value.

fn get_workable_slice_exact<'a>( &mut self, count: usize, ) -> Option<MutableSlice<'a, <Self as MRBIterator>::Item>>

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

fn get_workable_slice_avail<'a>( &mut self, ) -> Option<MutableSlice<'a, <Self as MRBIterator>::Item>>

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

fn get_workable_slice_multiple_of<'a>( &mut self, rhs: usize, ) -> Option<MutableSlice<'a, <Self as MRBIterator>::Item>>

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

impl<B: ConcurrentRB + MutRB<Item = T>, T, const W: bool> Send for ConsIter<'_, B, W>