Struct StreamAccumulator 

pub struct StreamAccumulator { /* private fields */ }

Manages the accumulation and merging of content deltas for streaming responses

Implementations

impl StreamAccumulator

pub fn new() -> Self

Creates a new StreamAccumulator

pub fn add_partial( &mut self, partial: PartialModelResponse, ) -> Result<(), String>

Adds a chunk of content deltas to the accumulator

Errors

Returns an error if delta types mismatch for the same index

pub fn compute_response(self) -> LanguageModelResult<ModelResponse>

Computes the final response from accumulated deltas

Errors

Returns an error if required fields are missing or format is unsupported

pub fn clear(&mut self)

Clears all accumulated data

pub fn size(&self) -> usize

Gets the number of accumulated parts

pub fn is_empty(&self) -> bool

Checks if the accumulator has any data

Trait Implementations

impl Default for StreamAccumulator

fn default() -> Self

Returns the “default value” for a type.