pub trait LiveStream: Send + Sync { // Required method fn subscribe(&self) -> Pin<Box<dyn Stream<Item = LiveEvent> + Send>>; }
Source of LiveEvents. Subscribers each get an independent stream.
LiveEvent