id_effect 0.2.0

Effect<A, E, R> (sync + async), context/layers, pipe — interpreter-style, no bundled executor
Documentation 
1
2
3
4
5
6
7
8
9
10
11

//! Ex 065 — `grouped` batches elements into fixed-size vectors.
use id_effect::{Stream, run_blocking};

fn main() {
  let s = Stream::range(1, 7).grouped(2).run_collect();
  assert_eq!(
    run_blocking(s, ()),
    Ok(vec![vec![1, 2], vec![3, 4], vec![5, 6]])
  );
  println!("065_stream_grouped ok");
}