Struct Accumulator 

pub struct Accumulator {
    pub content: String,
    pub tool_calls: Vec<ToolCallOut>,
    pub input_tokens: u64,
    pub output_tokens: u64,
    pub finish_reason: FinishReason,
    pub got_done: bool,
}

Folds a stream of StreamItem into final content + tool calls + usage. Used by the buffered consumer and (for the running totals) by the stream guard.

Fields

content: String

tool_calls: Vec<ToolCallOut>

input_tokens: u64

output_tokens: u64

finish_reason: FinishReason

got_done: bool

Implementations

impl Accumulator

pub fn push(&mut self, item: StreamItem)

Fold one item into the running result.

Assumes ToolCallDelta.index values are dense and 0-based — which both lanes guarantee by construction (the standard lane assigns indices by first-seen call id, the native lane by a running counter). A sparse index would leave empty ToolCallOut slots; we never produce one.

pub fn has_tool_calls(&self) -> bool

pub fn to_openai_response(&self, id: &str, model: &str) -> Value

Serialize the accumulated result as an OpenAI chat.completion object.

Trait Implementations

impl Debug for Accumulator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Accumulator

fn default() -> Self

Returns the “default value” for a type.