Struct orx_concurrent_iter::ConIterOfVec

pub struct ConIterOfVec<T: Send + Sync + Default> { /* private fields */ }

A concurrent iterator over a vector, consuming the vector and yielding its elements.

Implementations

impl<T: Send + Sync + Default> ConIterOfVec<T>

pub fn new(vec: Vec<T>) -> Self

Consumes and creates a concurrent iterator of the given vec.

Trait Implementations

impl<T: Send + Sync + Default> AtomicIter for ConIterOfVec<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_one(&self) -> Option<Next<Self::Item>>

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

fn fetch_n( &self, n: usize ) -> NextMany<Self::Item, impl Iterator<Item = 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.

impl<T: Send + Sync + Default> AtomicIterWithInitialLen for ConIterOfVec<T>

fn initial_len(&self) -> usize

Returns the initial length of the atomic iterator.

impl<T: Debug + Send + Sync + Default> Debug for ConIterOfVec<T>

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

Formats the value using the given formatter.

impl<T: Send + Sync + Default> From<Vec<T>> for ConIterOfVec<T>

fn from(vec: Vec<T>) -> Self

Consumes and creates a concurrent iterator of the given vec.

impl<T: Send + Sync + Default> Send for ConIterOfVec<T>

impl<T: Send + Sync + Default> Sync for ConIterOfVec<T>