Struct StreamRegistry 

pub struct StreamRegistry { /* private fields */ }

Per-session registry of SSE streams. See the module docs for the rules it enforces.

Implementations

impl StreamRegistry

pub fn new(config: StreamConfig) -> Self

Create a registry with the given configuration.

pub fn open( self: &Arc<Self>, prime_event_type: &str, prime_data: String, ) -> (StreamHandle, StoredEvent)

Open a new stream, storing and queueing a priming event (spec: the server SHOULD immediately send an event with an id so the client can reconnect with Last-Event-ID). Returns the handle and the priming event.

pub fn resume( self: &Arc<Self>, last_event_id: &str, ) -> Option<(StreamHandle, Vec<StoredEvent>)>

Resume the stream named by last_event_id ({stream_id}-{seq}), returning a fresh handle for the SAME stream identity plus the buffered events after the cursor. None if the id does not parse, the stream is unknown, or its buffer has been reaped.

A resumed stream keeps its id — and therefore its designation if it was the designated stream.

pub fn send(&self, event_type: &str, data: String) -> Option<String>

Store data on the designated stream (the oldest live one) and queue it for delivery, returning the allocated event id. None when the session has no live stream.

A full channel kills the stream (explicitly, never a silent skip); the event stays in that stream’s buffer, so the client’s resumption GET replays it. The event is NOT re-sent on another stream — it belongs to the stream it was stored on (spec: no cross-stream replay).

pub fn has_live_stream(&self) -> bool

Whether any stream is currently live.

Trait Implementations

impl Debug for StreamRegistry

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

Formats the value using the given formatter.

impl NotificationSink for StreamRegistry

fn publish(&self, notification: Notification)

Hand the notification to this transport’s outbound path.