7 releases

0.2.2 Dec 7, 2023
0.2.1 Nov 29, 2023
0.1.3 Jan 22, 2022

#4 in #loop

Download history 3269/week @ 2024-07-26 2504/week @ 2024-08-02 2307/week @ 2024-08-09 1899/week @ 2024-08-16 2136/week @ 2024-08-23 2253/week @ 2024-08-30 2586/week @ 2024-09-06 1952/week @ 2024-09-13 2130/week @ 2024-09-20 1950/week @ 2024-09-27 2391/week @ 2024-10-04 2290/week @ 2024-10-11 2503/week @ 2024-10-18 1095/week @ 2024-10-25 1941/week @ 2024-11-01 1879/week @ 2024-11-08

8,020 downloads per month
Used in risinglight

MIT/Apache

12KB
186 lines

iter-chunks

Yet another crate to provides chunks method to rust Iterator.

Please read the API documentation here.

Usage

Add this to your Cargo.toml:

[dependencies]
iter-chunks = "0.2"

Examples

Currently, only while loop over Chunks is supported.

use iter_chunks::IterChunks;

let arr = [1, 1, 2, 2, 3];
let expected = [vec![1, 1], vec![2, 2], vec![3]];
let mut chunks = arr.into_iter().chunks(2);
let mut i = 0;
while let Some(chunk) = chunks.next() {
    assert_eq!(chunk.collect::<Vec<_>>(), expected[i]);
    i += 1;
}

Why create this crate?

itertools provides many awesome extensions, including chunks. It's really useful, but it use RefCell internally, causing it's not Send.

It's a very common usecase in async context, which requires Chunks to be Send:

async fn do_some_work(input: impl Iterator<Item = i32>) {
    for chunk in input.chunks(1024) {
        for v in chunk {
            handle(v).await
        }
        do_some_flush().await
    }
}

This crate implements chunks without RefCell, so Chunks is both Send and Sync. As a price, Chunks cannot implement Iterator (which can be resolved later by GAT and LendingIterator).

Future works

The lack of the Iterator implementation is very difficult to use, and the best solution is to wait for GAT and a suitable LendingIterator crate. But in the short term, we can consider providing some common methods such as nth, for_each, try_for_each, and so on.

Contributions are welcome.

License

Licensed under either of

at your option.

No runtime deps