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

#![allow(clippy::type_complexity)]

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

pub trait ParUseOptionCore: IntoIterator<Item = Option<Self::Elem>> {
    type Elem;

    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 = Option<Self::M>>;

    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,
    );
}