Struct SseManager 

pub struct SseManager { /* private fields */ }

SSE connection manager

Implementations

impl SseManager

pub fn new() -> Self

Create a new SSE manager

pub async fn create_connection(&self, connection_id: String) -> SseConnection

Create a new SSE connection

pub async fn remove_connection(&self, connection_id: &str)

Remove a connection

pub async fn broadcast(&self, event: SseEvent)

Broadcast an event to all connections

pub async fn send_data(&self, data: Value)

Send data to all connections

pub async fn send_error(&self, message: String)

Send error to all connections

pub async fn send_keep_alive(&self)

Send keep-alive ping

pub async fn connection_count(&self) -> usize

Get number of active connections

Trait Implementations

impl Default for SseManager

fn default() -> Self

Returns the “default value” for a type.