orx-parallel 4.0.0

Performant parallel computations with an expressive iterator API.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

pub struct NextN<'a, I: Iterator> {
    iter: &'a mut I,
    n: usize,
    taken: usize,
}

impl<'a, I: Iterator> NextN<'a, I> {
    pub fn new(iter: &'a mut I, n: usize) -> Self {
        Self { iter, n, taken: 0 }
    }
}

impl<'a, I: Iterator> Iterator for NextN<'a, I> {
    type Item = I::Item;

    fn next(&mut self) -> Option<Self::Item> {
        match self.taken < self.n {
            true => {
                self.taken += 1;
                self.iter.next()
            }
            false => None,
        }
    }
}