Struct AnthropicMessagesStreamingCodec 

pub struct AnthropicMessagesStreamingCodec { /* private fields */ }

Streaming counterpart to AnthropicMessagesCodec.

Replays the Anthropic Messages SSE event sequence into the same JSON shape Anthropic returns for a non-streaming request ({id, type, role, model, content, stop_reason, stop_sequence, usage}). Once finalized, the assembled JSON can be fed back through AnthropicMessagesCodec::decode_response to produce an AnnotatedLlmResponse — meaning streaming and non-streaming Anthropic requests converge on the same observability output.

Internal state lives behind Arc<Mutex<...>> so the &self-produced collector and finalizer closures share access. Each instance is single-use because LlmFinalizerFn consumes the finalize step.

Implementations

impl AnthropicMessagesStreamingCodec

pub fn new() -> Self

Creates a fresh streaming codec with empty accumulator state.

Trait Implementations

impl Default for AnthropicMessagesStreamingCodec

fn default() -> Self

Returns the “default value” for a type.

impl StreamingCodec for AnthropicMessagesStreamingCodec

fn collector(&self) -> LlmCollectorFn

Returns a closure that consumes one decoded provider event per call.

fn finalizer(&self) -> LlmFinalizerFn

Returns a closure that, when called once at end of stream, produces the assembled response payload in the shape the matching crate::codec::traits::LlmResponseCodec can decode.