Struct SseBroadcaster 

pub struct SseBroadcaster<T> { /* private fields */ }

Small typed SSE broadcaster built on tokio::sync::broadcast.

• T must be Clone so multiple subscribers can receive the same payload.
• Bounded channel drops oldest events when subscribers lag (by design).

Implementations

impl<T: Clone + Send + 'static> SseBroadcaster<T>

pub fn new(capacity: usize) -> Self

Create a broadcaster with bounded buffer capacity.

pub fn send(&self, value: T)

Broadcast a single message to current subscribers. Errors are ignored to keep the hot path cheap (e.g., no active subscribers).

pub fn subscribe_stream(&self) -> impl Stream<Item = T> + use<T>

Subscribe to a typed stream of messages; lag/drop errors are filtered out.

pub fn sse_response( &self, ) -> Sse<impl Stream<Item = Result<Event, Infallible>> + use<T>>

where T: Serialize,

Plain SSE (no extra headers), unnamed events. Includes periodic keepalive pings to avoid idle timeouts.

pub fn sse_response_with_headers<I>(&self, headers: I) -> Response

where T: Serialize, I: IntoIterator<Item = (HeaderName, HeaderValue)>,

SSE with custom headers applied on top of the Sse response (unnamed events).

pub fn sse_response_named<N>( &self, event_name: N, ) -> Sse<impl Stream<Item = Result<Event, Infallible>> + use<T, N>>

where T: Serialize, N: Into<Cow<'static, str>> + 'static,

Plain SSE with a constant event: name for all messages (no extra headers).

pub fn sse_response_named_with_headers<I>( &self, event_name: impl Into<Cow<'static, str>> + 'static, headers: I, ) -> Response

where T: Serialize, I: IntoIterator<Item = (HeaderName, HeaderValue)>,

SSE with custom headers and a constant event: name for all messages.

Trait Implementations

impl<T: Clone> Clone for SseBroadcaster<T>

fn clone(&self) -> SseBroadcaster<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.