Struct SseSender 

pub struct SseSender { /* private fields */ }

Sends events to one streaming SSE response; clone it to send from several places. The stream ends when the last clone is dropped.

Implementations

impl SseSender

pub fn send(&self, event: SseEvent) -> Result<(), SseClosed>

Send event, waiting while the buffer is full (a slow client slows the sender down rather than growing memory). Blocks the thread: in async code use Self::send_async or Self::try_send.

pub fn try_send(&self, event: SseEvent) -> Result<bool, SseClosed>

Send event if there’s room: Ok(false) when the buffer is full and the event was dropped.

pub async fn send_async(&self, event: SseEvent) -> Result<(), SseClosed>

Self::send without blocking the async runtime: waits for room with short sleeps.

pub fn data(&self, data: &str) -> Result<(), SseClosed>

Send a data-only event (the client’s message event).

pub fn comment(&self, text: &str) -> Result<(), SseClosed>

Send a comment line (ignored by clients).

Trait Implementations

impl Clone for SseSender

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.