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
44
45
46
47

//! Moirai Iterator - Unified high-performance iterator system for concurrent, parallel, and async computing.
//!
//! This module provides a comprehensive iterator framework that abstracts over different execution contexts:
//! - **Parallel**: CPU-bound work across multiple threads with work-stealing
//! - **Async**: I/O-bound work with efficient async/await patterns
//! - **Hybrid**: Mixed workloads combining parallel and async execution
//!
//! # Design Principles
//!
//! - **Zero-cost abstractions**: Compile-time optimizations with no runtime overhead
//! - **Memory efficiency**: NUMA-aware allocation and cache-friendly data layouts
//! - **Execution agnostic**: Same API works across all execution contexts
//! - **Type safety**: Comprehensive compile-time guarantees
//! - **Performance**: SIMD vectorization and CPU optimization
//! - **Async compatibility**: Native async/await support throughout

#![deny(missing_docs)]
pub mod advanced_patterns;
pub mod async_iter;
pub mod base;
pub mod cache;
pub mod channel_fusion;
pub mod combinators;
pub mod execution;
pub mod facade;
pub mod iter_ops;
pub mod parallel;
pub mod prefetch;
pub mod simd_iter;
pub mod stream;
#[cfg(test)]
mod test_support;
pub mod windows;

pub use async_iter::{AsyncIterator, AsyncParallelIterator, IntoAsyncIterator};
pub use execution::{
    AsyncContext, ExecutionBase, ExecutionContext, ExecutionStrategy, HybridConfig, HybridContext,
    ParallelContext, PerformanceHistory,
};
pub use facade::{
    MoiraiIterator, async_range, moirai_iter, moirai_iter_async, moirai_iter_hybrid,
    moirai_iter_parallel, par_range,
};
pub use parallel::{
    IndexedParallelIterator, IntoParallelIterator, IntoParallelRefIterator, ParallelExtend,
    ParallelIterator, ParallelSliceMut, RangeParIter, VecParIter, VecRefParIter,
};