Struct AnthropicMessagesStreamCodec 

pub struct AnthropicMessagesStreamCodec;

Stream codec for Anthropic Messages events.

Trait Implementations

impl StreamCodec for AnthropicMessagesStreamCodec

fn format(&self) -> FormatId

Returns the stream format handled by this codec.

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.