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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

#![allow(clippy::type_complexity)]

use crate::use_var::Use;
use crate::{Params, infallible_use::XapUse, runner::ParRunner, sizes::SizePair};
use orx_concurrent_iter::ConcurrentIter;

pub trait ParUseResultCore: IntoIterator<Item = Result<Self::Elem, Self::Error>> {
    type Elem;

    type Error;

    type Runner: ParRunner;

    type Use;

    type Using: Use<Item = Self::Use>;

    type Input: ConcurrentIter;

    type M;

    type Xap1: XapUse<
            U = Self::Use,
            I = <Self::Input as ConcurrentIter>::Item,
            O = Result<Self::M, Self::Error>,
        >;

    type Xap2: XapUse<U = Self::Use, I = Self::M, O = Self::Elem>;

    type Size: SizePair<S1 = <Self::Xap1 as XapUse>::Size, S2 = <Self::Xap2 as XapUse>::Size>;

    fn destruct(
        self,
    ) -> (
        Self::Using,
        Self::Input,
        Self::Xap1,
        Self::Xap2,
        Self::Runner,
        Self::Size,
        Params,
    );
}