Struct SseEventParser 

pub struct SseEventParser { /* private fields */ }

Incremental SSE event parser.

Unlike extract_sse_data_lines, this parser follows event boundaries and joins multiple data: lines in the same event with \n.

Implementations

impl SseEventParser

pub fn new() -> Self

Create a new empty SSE event parser.

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

Push a transport byte chunk and return completed SSE event payloads.

pub fn finish(&mut self) -> Vec<Vec<u8>>

Flush any event buffered by data: lines that never saw a terminating blank line.

Per the SSE spec an event is dispatched on a blank line. If the transport closes after a final data: {...}\n with no following blank line (a reverse proxy stripping trailing whitespace, a truncated TLS frame at connection close, a non-conformant emitter), SseEventParser::push leaves that event buffered in event_data and it would otherwise be silently dropped — including the last content/usage chunk, or even the [DONE] marker if its trailing blank line was lost.

Call this once the byte stream has ended to emit any such trailing event. Returns an empty Vec when nothing is buffered. Any incomplete line still in buf (a data: line with no trailing newline) is intentionally NOT emitted — it is not a complete SSE line.

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.