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

#![allow(clippy::type_complexity)]

use crate::{Params, infallible::Xap, runner::ParRunner, sizes::SizePair};
use orx_concurrent_iter::ConcurrentIter;

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

    type Error;

    type Runner: ParRunner;

    type Input: ConcurrentIter;

    type M;

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

    type Xap2: Xap<I = Self::M, O = Self::Elem>;

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

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