Struct StreamAccumulator 

pub struct StreamAccumulator { /* private fields */ }

Accumulates streaming deltas from a provider into a complete assistant message and zero or more tool calls. Tracks both text content and partial tool call arguments until all deltas are received.

Implementations

impl StreamAccumulator

pub fn new() -> Self

Creates a new accumulator.

pub fn append_text(&mut self, delta: &str)

Appends a text delta chunk to the internal buffer.

pub fn start_tool_call(&mut self, id: String, name: String)

Starts a tool call.

pub fn append_tool_arguments(&mut self, id: &str, delta: &str)

Appends arguments to a tool call.

pub fn text(&self) -> &str

Returns the accumulated text.

pub fn tool_calls(&self) -> Vec<ToolCall>

Parses accumulated tool call arguments into ToolCall values. Unparseable JSON arguments produce a serde_json::Value::Null fallback.

pub fn to_message(&self) -> Message

Assembles an assistant Message from the accumulated text and tool calls. Handles three cases:

• Neither text nor tool calls → empty assistant message.
• Text only → Message::assistant_text.
• Tool calls present (with optional text) → structured Message::Assistant.

pub fn clear(&mut self)

Clears the accumulator.

Trait Implementations

impl Debug for StreamAccumulator

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

Formats the value using the given formatter.

impl Default for StreamAccumulator

fn default() -> StreamAccumulator

Returns the “default value” for a type.