Trait Decoder 

pub trait Decoder<'id, Op: Operation, Frame = WireFrame> {
    type Event;

    // Required methods
    fn classify(&self, frame: Frame) -> WireEvent<Self::Event>;
    fn decode(
        &mut self,
        event: Self::Event,
        out: Out<'id, Op>,
    ) -> Result<Flow, ProviderError>;

    // Provided method
    fn eof(&mut self, out: Out<'id, Op>) -> Result<Flow, ProviderError> { ... }
}

Synchronous state machine for one reply. It classifies frames and decodes known events into the reply’s writer, without transport access and without being told how the reply arrives. HTTP wires read WireFrames; other transports name their own frame type.

Required Associated Types

type Event

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

Required Methods

fn classify(&self, frame: Frame) -> WireEvent<Self::Event>

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: Self::Event, out: Out<'id, Op>, ) -> Result<Flow, ProviderError>

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

Provided Methods

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.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<'id, Op> Decoder<'id, Op> for Json

where Op: Operation<Emit = Free>, Op::End: DeserializeOwned,

type Event = (<Op as Operation>::End, Value)

impl<'id> Decoder<'id, AudioGeneration> for SpeechDecoder

Available on crate feature audio only.

type Event = Vec<u8>

impl<'id> Decoder<'id, Completion, MockFrame> for MockDecoder<'id>

Available on crate feature test-utils only.

type Event = MockFrame

impl<'id> Decoder<'id, Completion> for rig_core::providers::cohere::streaming::ChatDecoder

type Event = ChatEvent

impl<'id> Decoder<'id, Completion> for rig_core::providers::ollama::streaming::ChatDecoder

type Event = ChatRecord

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

type Event = CohereEvent

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

type Event = GenerateContentChunk

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

EOF without interaction.completed is truncation, not successful completion, so the decoder has nothing to add at the end of the reply.

type Event = InteractionsEvent

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

type Event = MessagesEvent

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

type Event = OpenAiEvent

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

type Event = ResponsesEvent

impl<'id> Decoder<'id, ContextCache> for CachedContentsDecoder

type Event = CachedContentReply

impl<'id> Decoder<'id, Embedding> for rig_core::providers::cohere::embeddings::EmbeddingsDecoder

type Event = Result<EmbeddingResponse, String>

impl<'id> Decoder<'id, Embedding> for rig_core::providers::gemini::embedding::EmbeddingsDecoder

type Event = EmbeddingResponse

impl<'id> Decoder<'id, Embedding> for rig_core::providers::ollama::embedding::EmbeddingsDecoder

type Event = EmbeddingResponse

impl<'id> Decoder<'id, Embedding> for rig_core::providers::openai::wire::EmbeddingsDecoder

type Event = CompatibleEmbeddingResponse

impl<'id> Decoder<'id, Embedding> for rig_core::providers::voyageai::wire::EmbeddingsDecoder

type Event = EmbeddingResponse

impl<'id> Decoder<'id, ImageEmbedding> for ImageEmbeddingsDecoder

type Event = Result<ImageEmbeddingResponse, String>

impl<'id> Decoder<'id, ImageGeneration> for rig_core::providers::gemini::image_generation::ImagesDecoder

Available on crate feature image only.

type Event = Value

impl<'id> Decoder<'id, ImageGeneration> for rig_core::providers::openai::wire::ImagesDecoder

Available on crate feature image only.

type Event = ImagesEvent

impl<'id> Decoder<'id, ModelListing> for rig_core::providers::anthropic::modality::ModelsDecoder

type Event = ModelsPage

impl<'id> Decoder<'id, ModelListing> for rig_core::providers::copilot::model_listing::ModelsDecoder

type Event = Value

impl<'id> Decoder<'id, ModelListing> for rig_core::providers::gemini::model_listing::ModelsDecoder

type Event = String

impl<'id> Decoder<'id, ModelListing> for rig_core::providers::ollama::model_listing::ModelsDecoder

type Event = ListModelsResponse

impl<'id> Decoder<'id, ModelListing> for rig_core::providers::openai::wire::ModelsDecoder

type Event = ModelsReply

impl<'id> Decoder<'id, Rerank> for rig_core::providers::openai::wire::RerankDecoder

type Event = RerankReply

impl<'id> Decoder<'id, Rerank> for rig_core::providers::voyageai::wire::RerankDecoder

type Event = Result<RerankApiResponse, String>

impl<'id> Decoder<'id, Transcription> for rig_core::providers::gemini::transcription::TranscriptionsDecoder

type Event = Value

impl<'id> Decoder<'id, Transcription> for rig_core::providers::openai::wire::TranscriptionsDecoder

type Event = TranscriptionResponse

impl<'id> Decoder<'id, Verify> for VerifyDecoder

type Event = ()

impl<'id> Decoder<'id, Verify> for VerifyKeyDecoder

type Event = ()