Struct ResponsesDecoder 

pub struct ResponsesDecoder { /* private fields */ }

The OpenAI Responses wire’s decoder: one state machine for the SSE stream, the unary body and the websocket session.

Each output item becomes one block. It opens when it is announced, or at its first delta, with no provider item, and its done item closes it, becoming the block’s native: an item the provider never stated complete replays from its canonical fields. A done item merges into what streamed: a call keeps the id and name it was announced with and the arguments it streamed when its done item leaves them out, and text the done item leaves out stays, written into the item. The terminal response is the whole output: it finishes the items no done event carried, writes the ones the stream never stated, which is how a unary body decodes, and backfills the ciphertext of reasoning done without it.

Implementations

impl ResponsesDecoder

pub fn new() -> Self

A decoder for one reply of a Responses endpoint.

Trait Implementations

impl<'id> Decoder<'id, Completion> for ResponsesDecoder

type Event = ResponsesEvent

The wire’s typed event, produced by this decoder’s classifier.

fn classify(&self, frame: WireFrame) -> WireEvent<ResponsesEvent>

Decode and classify one frame. A JSON wire MUST delegate to a classifier in crate::providers::internal::wire, so the decode-then-validate policy is not re-derived per provider.

fn decode( &mut self, event: ResponsesEvent, out: Out<'id, Completion>, ) -> Result<Flow, ProviderError>

Write one Known event into the reply. An error ends the reply with it.

fn eof(&mut self, out: Out<'id, Op>) -> Result<Flow, ProviderError>

The frames ran out without an end. A decoder that already saw the provider’s end, in a form the provider sends before its last frame, ends the reply here; otherwise the reply is truncated.

impl Default for ResponsesDecoder

fn default() -> Self

Returns the “default value” for a type.