Struct SSEBroadcaster 

pub struct SSEBroadcaster { /* private fields */ }

Lock-free SSE broadcaster using DashMap

All operations are non-blocking using DashMap for client tracking and tokio unbounded channels for message passing.

Implementations

impl SSEBroadcaster

pub fn new() -> SSEBroadcaster

Create a new broadcaster with no connected clients.

pub fn register_client(&self, id: Uuid) -> UnboundedReceiver<SseEvent>

Register a new client (lock-free)

pub fn unregister_client(&self, id: &Uuid)

Unregister a client (lock-free)

pub fn broadcast(&self, event: SseEvent)

Broadcast event to all clients (lock-free)

pub fn send_to_client( &self, client_id: &Uuid, event: SseEvent, ) -> Result<(), String>

Send event to specific client (lock-free)

pub fn active_clients(&self) -> u64

Get active client count (atomic read)

pub fn total_events(&self) -> u64

Get total events broadcasted (atomic read)

Trait Implementations

impl Default for SSEBroadcaster

fn default() -> SSEBroadcaster

Returns the “default value” for a type.