method Broadcast.publish

use std.stream { Broadcast }

data Tick { px: i32 }

fn main() io, time {
  let hub = Broadcast<Tick>.new(buffer: 4)
  var a = hub.subscribe()
  var b = hub.subscribe()
  hub.publish(Tick{ px: 7 })
  var total = 0
  match a.pullWithin(1s) {
    Pulled.Item(t) => total += t.px
    _ => {}
  }
  match b.pullWithin(1s) {
    Pulled.Item(t) => total += t.px
    _ => {}
  }
  print("{total}")
}

14