Struct orx_concurrent_iter::ConIterOfArray

pub struct ConIterOfArray<const N: usize, T: Send + Sync + Default> { /* private fields */ }

A concurrent iterator over an array, consuming the array and yielding its elements.

Implementations

impl<const N: usize, T: Send + Sync + Default> ConIterOfArray<N, T>

pub fn new(array: [T; N]) -> Self

Consumes and creates a concurrent iterator of the given array.

Trait Implementations

impl<const N: usize, T: Send + Sync + Default> AtomicIter for ConIterOfArray<N, 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<const N: usize, T: Send + Sync + Default> AtomicIterWithInitialLen for ConIterOfArray<N, T>

fn initial_len(&self) -> usize

Returns the initial length of the atomic iterator.

fn fetch_n_with_exact_len( &self, n: usize ) -> NextManyExact<Self::Item, impl ExactSizeIterator<Item = Self::Item>>

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

impl<const N: usize, T: Debug + Send + Sync + Default> Debug for ConIterOfArray<N, T>

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

Formats the value using the given formatter.

impl<const N: usize, T: Send + Sync + Default> From<[T; N]> for ConIterOfArray<N, T>

fn from(array: [T; N]) -> Self

Consumes and creates a concurrent iterator of the given array.

impl<const N: usize, T: Send + Sync + Default> Send for ConIterOfArray<N, T>

impl<const N: usize, T: Send + Sync + Default> Sync for ConIterOfArray<N, T>