Module channel_broker 

ChannelBroker adapter — MessageBroker port backed by tokio::sync::broadcast.

Each topic gets its own broadcast channel with capacity 64. Publishers fan-out to all subscribers; slow subscribers lag (messages are dropped) rather than blocking the publisher.

Structs

ChannelBroker

Thread-safe, cheaply cloneable pub/sub broker backed by tokio broadcast channels.