fn throttle

use std.stream { throttle }

fn nums() -> stream<i32> {
  for i in 1..=3 { yield i }
}

fn main() io, time {
  var out: List<i32> = []
  // all three arrive within the interval: only the first passes
  for await x in nums() |> throttle(1h) {
    out.push(x)
  }
  print("{out}")
}

[1]