Struct SseTransformer 

pub struct SseTransformer { /* private fields */ }

Implementations

impl SseTransformer

pub fn new( pair: TransformPair, ctx: TransformContext, ) -> Result<Self, TransformError>

pub fn with_options( pair: TransformPair, ctx: TransformContext, options: StreamOptions, ) -> Result<Self, TransformError>

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

Feed one upstream chunk; returns encoded inbound bytes (possibly empty).

pub fn push_detailed( &mut self, chunk: &[u8], ) -> Result<TransformOutput<Vec<u8>>, TransformError>

Feed one chunk and return semantic diagnostics produced by its events.

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

Flush the trailing frame and emit the inbound terminator.

pub fn finish_detailed( &mut self, ) -> Result<TransformOutput<Vec<u8>>, TransformError>

Flush the stream and return final semantic diagnostics.

pub fn diagnostics(&self) -> StreamDiagnostics