Struct SseToNdjsonRewriter 

pub struct SseToNdjsonRewriter { /* private fields */ }

Incremental SSE -> NDJSON converter.

Feed bytes via SseToNdjsonRewriter::push_chunk, then call SseToNdjsonRewriter::finish when upstream ends.

Implementations

impl SseToNdjsonRewriter

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

Pushes one upstream chunk and returns converted NDJSON bytes ready for downstream emission.

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

Flushes trailing buffered bytes (if any) at stream end.

Trait Implementations

impl Clone for SseToNdjsonRewriter

fn clone(&self) -> SseToNdjsonRewriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SseToNdjsonRewriter

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

Formats the value using the given formatter.

impl Default for SseToNdjsonRewriter

fn default() -> SseToNdjsonRewriter

Returns the “default value” for a type.

impl PartialEq for SseToNdjsonRewriter

fn eq(&self, other: &SseToNdjsonRewriter) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for SseToNdjsonRewriter

impl StructuralPartialEq for SseToNdjsonRewriter