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_checked.

new uses DEFAULT_MAX_LINE_BYTES for both a single line and the accumulated data: payload in one record. unbounded is the explicit opt-out for trusted in-memory inputs.

Implementations

impl SseDecoder

pub fn new() -> Self

Create an empty decoder using DEFAULT_MAX_LINE_BYTES.

pub fn unbounded() -> Self

Create an empty decoder with no line or event-data limit.

Use this only for trusted, already-bounded inputs.

pub fn with_max_line_bytes(max_line_bytes: usize) -> Self

Create an empty decoder that rejects any line, buffered partial line, or accumulated record data longer than max_line_bytes.

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

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

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

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 push_line_checked( &mut self, line: &str, ) -> Result<Option<SseEvent>, NetError>

Feed a single already-framed line, checking line and accumulated data bounds.

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).

pub fn flush_checked(&mut self) -> Result<Option<SseEvent>, NetError>

Flush any buffered partial line and any accumulated-but-undispatched record, checking configured bounds first.

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() -> Self

Returns the “default value” for a type.