Struct ResponsesDecoder 

pub struct ResponsesDecoder<'id> { /* private fields */ }

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

Implementations

impl<'id> ResponsesDecoder<'id>

pub fn new(provider: &str) -> Self

A decoder for one reply of provider’s Responses endpoint.

pub fn with_envelope_repair(self) -> Self

Salvage replayed frames that omit their envelope bookkeeping.

pub fn with_upstream_reasoning_issuer(self) -> Self

Record reasoning as issued by the upstream model’s family, for a gateway that relays each upstream’s own reasoning state.

pub fn with_initial_usage(self, usage: Option<ResponsesUsage>) -> Self

Seed the terminal’s usage for a replayed body whose frames may not carry one (the unary Responses body’s own usage).

Trait Implementations

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

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.