orx-parallel 3.4.0

High performance, configurable and expressive parallel computation library.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

pub struct ResultOfIter<I, E>
where
    I: Iterator,
{
    iter: Option<I>,
    error: Option<E>,
}

impl<I, E> ResultOfIter<I, E>
where
    I: Iterator,
{
    pub fn ok(iter: I) -> Self {
        Self {
            iter: Some(iter),
            error: None,
        }
    }

    pub fn err(error: E) -> Self {
        Self {
            iter: None,
            error: Some(error),
        }
    }
}

impl<I, E> Iterator for ResultOfIter<I, E>
where
    I: Iterator,
{
    type Item = Result<I::Item, E>;

    #[inline]
    fn next(&mut self) -> Option<Self::Item> {
        match self.iter.as_mut() {
            Some(iter) => iter.next().map(|x| Ok(x)),
            None => self.error.take().map(|e| Err(e)),
        }
    }
}