fn dedup

use std.stream { dedup }

fn nums() -> stream<i32> {
  for i in [1, 1, 2, 2, 2, 1] { yield i }
}

fn main() io {
  var out: List<i32> = []
  for await x in nums() |> dedup() { out.push(x) }
  print("{out}")
}

[1, 2, 1]