Struct StreamBroadcaster 

pub struct StreamBroadcaster { /* private fields */ }

A broadcast publisher for raw SSE strings.

StreamBroadcaster is cheap to clone — all clones share the same underlying broadcast::Sender. Each subscriber gets its own broadcast::Receiver from subscribe.

The capacity parameter controls the internal ring-buffer size. Slow subscribers that fall more than capacity messages behind will receive a [broadcast::error::RecvError::Lagged] error on the next recv() call; the broadcaster itself is never blocked.

Implementations

impl StreamBroadcaster

pub fn new(capacity: usize) -> Result<Self, AgentRuntimeError>

Create a new broadcaster with the given channel capacity.

Errors

Returns Err if capacity is zero (the broadcast channel requires a capacity of at least 1).

pub fn send(&self, sse_line: String) -> Result<usize, AgentRuntimeError>

Publish a raw SSE-formatted string to all active subscribers.

Returns the number of active receivers that received the message. A return value of 0 simply means there are no subscribers at this moment; it is not an error.

pub fn send_event(&self, event: &AgentEvent) -> Result<usize, AgentRuntimeError>

Publish an AgentEvent by converting it to SSE format first.

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

Create a new subscriber receiver.

The receiver will see all messages published after this call.

pub fn receiver_count(&self) -> usize

Return the number of active subscribers.

Trait Implementations

impl Clone for StreamBroadcaster

fn clone(&self) -> StreamBroadcaster

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamBroadcaster

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.