Struct orx_concurrent_iter::ConIterOfIter

pub struct ConIterOfIter<T: Send + Sync, Iter>
where
    Iter: Iterator<Item = T>,
{ /* private fields */ }

A regular Iter: Iterator ascended to the concurrent programs with use of atomics.

Since ConIterOfIter can wrap up any Iterator and enable concurrent iteration, it might be considered as the most general ConcurrentIter implementation.

In performance critical scenarios and whenever possible, it might be preferable to use a more specific implementation such as crate::ConIterOfSlice.

Implementations

impl<T: Send + Sync, Iter> ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T>,

pub fn new(iter: Iter) -> Self

Creates a concurrent iterator for the given iter.

Trait Implementations

impl<T: Send + Sync, Iter> AtomicIter for ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T>,

type Item = T

Type of the items that the iterator yields.

fn counter(&self) -> &AtomicCounter

Returns a reference to the underlying advanced item counter.

fn get(&self, item_idx: usize) -> Option<Self::Item>

Returns the item_idx-th item that the iterator yields; returns None if the iterator completes before.

fn fetch_n(&self, n: usize) -> impl NextChunk<Self::Item>

Returns an iterator of the next n consecutive items that the iterator yields. It might return an iterator of less or no items if the iteration does not have sufficient elements left.

fn fetch_one(&self) -> Option<Next<Self::Item>>

Returns the next item that the iterator yields; returns None if the iteration has completed.

impl<T: Debug + Send + Sync, Iter> Debug for ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T> + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Send + Sync, Iter> From<Iter> for ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T>,

fn from(iter: Iter) -> Self

Converts to this type from the input type.

impl<T: Send + Sync, Iter> Send for ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T>,

impl<T: Send + Sync, Iter> Sync for ConIterOfIter<T, Iter>

where Iter: Iterator<Item = T>,