moirai-iter 0.7.0

Parallel and async iterator combinators for Moirai concurrency 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
42
43

//! Parallel iterator implementation for Moirai.
//!
//! This module provides a focused Rayon-style adapter subset while integrating
//! with Moirai's scheduler and iterator consumers. The indexed boundary is
//! limited to exact-size source cardinality; full Rayon indexed producers remain
//! outside this adapter layer. Use `Moirai::for_each_indexed` and
//! `Moirai::map_reduce_indexed` for scheduler-owned indexed execution.

mod adapters;
mod consumers;
mod fallible;
mod indexed;
pub(crate) mod output;
mod sorting;
mod sources;
mod split;
#[cfg(test)]
mod tests;
mod traits;

pub use adapters::{
    Chain, Chunks, Cloned, Copied, Enumerate, ExponentialBlocks, Filter, FilterMap, FlatMap,
    Flatten, Inspect, Interleave, InterleaveShortest, Intersperse, Map, MapInit, MapPositions,
    MapWith, PanicFuse, Positions, Rev, Skip, SkipAnyWhile, StepBy, Take, TakeAnyWhile,
    UniformBlocks, Update, WhileSome, Zip, ZipEq,
};
pub use consumers::{Folded, Reduction};
pub use fallible::TryStreamItem;
pub use indexed::IndexedParallelIterator;
pub use sorting::ParallelSliceMut;
pub use sources::{
    RangeParIter, RefVecParIter, SequentialAdapter, SequentialIterAdapter, VecParIter,
    VecRefParIter,
};
pub use split::Either;
pub use traits::{
    Consumer, IntoParallelIterator, IntoParallelRefIterator, ParallelExtend, ParallelIterator,
};

use consumers::{
    CollectConsumer, FilterConsumer, FilterMapConsumer, FlatMapConsumer, FoldConsumer,
    InspectConsumer, MapConsumer, NullConsumer, ReduceConsumer, ShortCircuitConsumer,
};