Struct SseReader 

pub struct SseReader<R: BufRead> { /* private fields */ }

A blocking, line-based SSE reader. next_event accumulates field: value lines and emits one SseEvent per blank-line separator (multiple data: lines join with \n), returning Ok(None) at end of stream. Bounded per event by MAX_RESPONSE so a hostile stream cannot exhaust memory.

Implementations

impl<R: BufRead> SseReader<R>

pub fn new(r: R) -> SseReader<R>

pub fn next_event(&mut self) -> Result<Option<SseEvent>>

Read the next event, or Ok(None) at EOF. Comment lines (: prefix) and unknown fields are ignored per the SSE spec.