src/main.oxl

use self.pipeline { scaled, running, groups, collect, readings }
use std.stream { take, skip }

fn main() io, time {
  print("scaled  {collect(scaled(5))}")
  print("running {collect(running() |> skip(7))}")
  print("first 3 {collect(readings() |> take(3))}")
  var sizes: List<usize> = []
  for await g in groups(4) { sizes.push(g.len()) }
  print("groups  {sizes}")
}