Enum OpenAiDecoder 

pub enum OpenAiDecoder<'id> {
    Chat(ChatDecoder<'id>),
    Responses(ResponsesDecoder<'id>),
}

The chosen route’s decoder.

Variants

Chat(ChatDecoder<'id>)

The chat-completions state machine.

Responses(ResponsesDecoder<'id>)

The Responses state machine.

Trait Implementations

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

type Event = OpenAiEvent

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

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

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: OpenAiEvent, 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, Completion>) -> 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.