bring messagefanout;

let fanout = new messagefanout.MessageFanout();

fanout.addConsumer(inflight (msg: str) => {
  log("Hello {msg}!!!");
});

test "push a message to fanout" {
  fanout.publish("world");
}