Struct SseBroadcaster 

pub struct SseBroadcaster { /* private fields */ }

Broadcasts Events to SSE clients via a tokio::sync::broadcast channel.

Register this as an EventSubscriber on the Engine to forward all (or filtered) domain events to connected SSE clients.

Examples

use ironflow_api::sse::SseBroadcaster;

let broadcaster = SseBroadcaster::new();
assert_eq!(broadcaster.receiver_count(), 0);
let _receiver = broadcaster.subscribe();
assert_eq!(broadcaster.receiver_count(), 1);

Implementations

impl SseBroadcaster

pub fn new() -> Self

Create a new broadcaster with the default capacity (256).

Examples

use ironflow_api::sse::SseBroadcaster;

let broadcaster = SseBroadcaster::new();

pub fn with_capacity(capacity: usize) -> Self

Create a new broadcaster with a custom channel capacity.

Examples

use ironflow_api::sse::SseBroadcaster;

let broadcaster = SseBroadcaster::with_capacity(64);

pub fn subscribe(&self) -> Receiver<Event>

Create a new receiver for the broadcast channel.

Each SSE client connection calls this to get its own receiver.

pub fn receiver_count(&self) -> usize

Returns the number of active receivers (connected SSE clients).

pub fn sender(&self) -> Sender<Event>

Returns a clone of the underlying sender.

Stored in AppState so that the SSE route can create receivers without holding a reference to the broadcaster.

Trait Implementations

impl Default for SseBroadcaster

fn default() -> Self

Returns the “default value” for a type.

impl EventSubscriber for SseBroadcaster

fn name(&self) -> &str

A short identifier for this subscriber (used in logs).

fn handle<'a>(&'a self, event: &'a Event) -> SubscriberFuture<'a>

Handle a domain event.