Struct SseEventParser 

pub struct SseEventParser { /* private fields */ }

Stateful SSE event parser. Feed it complete LF-delimited lines via Self::push_line; it emits a complete SseEvent each time it sees a terminator blank line per W3C spec.

Implementations

impl SseEventParser

pub fn new() -> Self

pub fn push_line(&mut self, line: &str) -> Option<SseEvent>

Push one complete line. Returns Some(event) iff the line terminated an event (blank line); None while still accumulating fields.

Per W3C §“event stream interpretation”:

• event: <name> → set event name
• id: <id> → set last event id
• data: <line> → append (with newline) to data buffer
• retry: <ms> → set retry hint
• <empty line> → dispatch accumulated event
• : <comment> → ignore (comment line)
• other → ignore (unknown field)

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

Flush any pending event (no terminator blank line observed). Most providers do close the final event with a blank line so this is usually a no-op; it covers the edge case of a network drop mid-event or a non-compliant terminator-omitting server.

Trait Implementations

impl Debug for SseEventParser

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

Formats the value using the given formatter.

impl Default for SseEventParser

fn default() -> SseEventParser

Returns the “default value” for a type.