Struct SseDecoder 

pub struct SseDecoder { /* private fields */ }

Incremental Server-Sent Events decoder.

Accumulates event: and data: field lines and emits an SseEvent when a blank line terminates the record (standard SSE dispatch). Multiple data: lines within one record are joined with \n. Comment lines (those starting with :) and unknown fields are ignored. Field values have a single leading space after the colon stripped, per the SSE specification.

push does the newline framing internally via LineDecoder; callers that already have whole lines can use push_line.

Implementations

impl SseDecoder

pub fn new() -> Self

Create an empty decoder.

pub fn push(&mut self, bytes: &[u8]) -> Vec<SseEvent>

Feed raw bytes; return any records completed by blank lines.

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

Feed a single already-framed line (without its terminating newline). Returns an SseEvent when this line is the blank line that dispatches the accumulated record.

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

Flush any buffered partial line and any accumulated-but-undispatched record (a stream that ended without a final blank line).

Trait Implementations

impl Debug for SseDecoder

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

Formats the value using the given formatter.

impl Default for SseDecoder

fn default() -> SseDecoder

Returns the “default value” for a type.