orx-concurrent-iter 3.3.0

A thread-safe and ergonomic concurrent iterator trait and efficient lock-free implementations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use super::ConIterOfIter;
use crate::concurrent_iterable::ConcurrentIterable;
use orx_iterable::{Iterable, transformations::CloningIterable};

impl<I> ConcurrentIterable for CloningIterable<I>
where
    I: Iterator + Clone,
    I::Item: Send + Sync,
{
    type Item = I::Item;

    type Iter = ConIterOfIter<I>;

    fn con_iter(&self) -> Self::Iter {
        ConIterOfIter::new(self.iter())
    }
}