rinq 0.1.0

Type-safe, zero-cost LINQ-inspired query engine for Rust — filter, sort, aggregate, window analytics, parallel execution, and statistical extensions.
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

// rinq/examples/parallel_example.rs
// Demonstrates ParallelQueryBuilder (requires the "parallel" feature).

fn main() {
    #[cfg(feature = "parallel")]
    {
        use rinq::ParallelQueryBuilder;

        println!("=== RINQ Parallel Operations ===\n");

        let data: Vec<i32> = (1..=1_000_000).collect();

        let sum: i32 = ParallelQueryBuilder::from(data.clone())
            .par_where(|x| x % 2 == 0)
            .par_sum();

        println!("Sum of even values in 1..=1_000_000: {sum}");

        let count = ParallelQueryBuilder::from(data)
            .par_where(|x| *x % 3 == 0)
            .par_count();

        println!("Count of multiples of 3: {count}");
    }

    #[cfg(not(feature = "parallel"))]
    {
        println!("Run with --features parallel to see this example.");
        println!("  cargo run --example parallel_example --features parallel");
    }
}