Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.
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.
impl AnthropicMessagesStreamingCodecimpl AnthropicMessagesStreamingCodecnewpub fn new() -> SelfCreates a fresh streaming codec with empty accumulator state.
impl Default for AnthropicMessagesStreamingCodecimpl Default for AnthropicMessagesStreamingCodecdefaultfn default() -> Selfimpl StreamingCodec for AnthropicMessagesStreamingCodecimpl StreamingCodec for AnthropicMessagesStreamingCodeccollectorfn collector(&self) -> LlmCollectorFnfinalizerfn finalizer(&self) -> LlmFinalizerFn