Windowed acknowledged broadcast: many-to-many publisher/subscriber with per-listener sliding windows, three-channel message envelopes (SUCCESS/ERROR/CLOSED), and a small operator library (of, map, tap, reduce, scan, states, group, squash, after, poll, mat