Expand description
EventManager — collects registered sinks and starts the bus.
ⓘ
let mut manager = EventManager::new();
manager.register(Box::new(StderrSink::new(fmt)));
manager.register(Box::new(SqliteSink::new(store)));
let handle = manager.start();
let bus = handle.bus.clone();
// … use bus.emit(event) from the proxy hot path …
handle.shutdown().await;Structs§
- Event
Manager - Builder that holds the set of sinks to register before the bus starts.