Struct SseSink 

pub struct SseSink<'a> { /* private fields */ }

A flushing sink that formats Server-Sent Events (text/event-stream). Each call emits one event frame and flushes — exactly what LLM token streaming wants.

Implementations

impl<'a> SseSink<'a>

pub fn new(w: &'a mut dyn Write) -> SseSink<'a>

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

Send a data: event (multi-line data is split across data: lines).

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

Send a named event.

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

Send a comment line (: ...) — useful as a keep-alive heartbeat.

pub fn retry(&mut self, millis: u64) -> Result<()>

Suggest a client reconnection delay (ms).