Struct OpenAiSseState 

pub struct OpenAiSseState { /* private fields */ }

Incremental SSE assembler for one interpretation.

Implementations

impl OpenAiSseState

pub fn new( max_line_bytes: usize, max_event_bytes: usize, max_tool_arg_bytes: usize, ) -> Self

Construct with bounds from interpretation limits.

pub fn saw_done(&self) -> bool

Whether a terminal [DONE] marker was observed.

pub fn push_bytes( &mut self, chunk: &[u8], ) -> Result<Vec<AcpFragment>, InterpreterError>

Ingest a raw transport chunk; return fragments to apply.

pub fn seal_clean(&mut self) -> Result<Vec<AcpFragment>, InterpreterError>

Flush on clean end: incomplete trailing event without a DONE marker fails closed.

Trait Implementations

impl Debug for OpenAiSseState

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

Formats the value using the given formatter.

impl Default for OpenAiSseState

fn default() -> OpenAiSseState

Returns the “default value” for a type.