Struct OpenAiResponsesStreamCodec 

pub struct OpenAiResponsesStreamCodec;

Stream codec for OpenAI Responses API events.

Trait Implementations

impl StreamCodec for OpenAiResponsesStreamCodec

fn format(&self) -> FormatId

Returns the stream format handled by this codec.

fn is_terminal_event(&self, event: &Value) -> bool

Returns whether a JSON event establishes stream completion.

fn sse_done_is_terminal(&self) -> bool

Returns whether the SSE [DONE] marker establishes stream completion.

fn stamp_streamed_response_model(&self, event: &mut Value, served_model: &str)

Overrides the model reported by an encoded or preserved event.

fn decode_event( &self, state: &mut StreamTranslationState, event: &Value, ) -> Vec<LlmResponseChunk>

Decodes one provider event into zero or more neutral events.

fn encode_event( &self, state: &mut StreamTranslationState, event: LlmResponseChunk, ) -> Vec<Value>

Encodes one neutral event into zero or more provider events.

fn observe_replayed_event( &self, state: &mut StreamTranslationState, raw: &Value, normalized: Vec<LlmResponseChunk>, )

Advances encoder state after an exact same-format event replay.

fn finish(&self, state: &mut StreamTranslationState) -> Vec<Value>

Emits any terminal provider events needed after the source stream ends.