Expand description
The event stream.
Mirrors Flue’s observe / FlueEventSubscriber and event-stream-store.
Observers subscribe to a stream of Events (= fluers_core::RunEvent)
emitted as a session runs.
The Event type and the EventSink trait live
in fluers-core so that run_agent (which lives in core) can emit events
without creating a core → runtime dependency cycle. EventBus implements
that trait here.
Structs§
- Event
Bus - A fan-out event bus backed by a bounded broadcast channel.
Type Aliases§
- Event
- Re-export of the core run-lifecycle event type.