Struct StreamAccumulator 

pub struct StreamAccumulator { /* private fields */ }

Helper to accumulate streamed content into a final response.

This struct collects StreamDelta events and can convert them into the final content blocks once the stream is complete.

Implementations

impl StreamAccumulator

pub fn new() -> Self

Create a new empty accumulator.

pub fn apply(&mut self, delta: &StreamDelta)

Apply a stream delta to the accumulator.

pub const fn usage(&self) -> Option<&Usage>

Get the accumulated usage information.

pub const fn stop_reason(&self) -> Option<&StopReason>

Get the stop reason.

pub fn into_content_blocks(self) -> Vec<ContentBlock>

Convert accumulated content to ContentBlocks.

This consumes the accumulator and returns the final content blocks. Tool use JSON is parsed at this point; invalid JSON results in a null input.

pub const fn take_usage(&mut self) -> Option<Usage>

Take ownership of accumulated usage.

pub const fn take_stop_reason(&mut self) -> Option<StopReason>

Take ownership of stop reason.

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.