Struct StreamCollector 

pub struct StreamCollector { /* private fields */ }

Collector for streaming LLM responses.

Processes stream events and accumulates text and tool calls.

Implementations

impl StreamCollector

pub fn new() -> Self

Create a new stream collector.

pub fn into_partial_text(self) -> String

Consume the collector and return only the accumulated text.

Used for stream error recovery: partial tool calls are discarded (incomplete JSON arguments are not usable), but text is preserved.

pub fn process(&mut self, event: ChatStreamEvent) -> Option<StreamOutput>

Process a stream event and optionally return an output event.

This is a pure-ish function - it updates internal state and returns an output event if something notable happened.

pub fn finish(self, max_output_tokens: Option<u32>) -> StreamResult

Finish collecting and return the final result.

max_output_tokens is used to infer StopReason::MaxTokens when the backend does not provide an explicit stop reason (e.g. genai). Pass None to skip inference; the stop_reason field will be set based on tool call presence only.

pub fn text(&self) -> &str

Get the current accumulated text.

pub fn has_tool_calls(&self) -> bool

Check if any tool calls have been collected.

Trait Implementations

impl Debug for StreamCollector

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

Formats the value using the given formatter.

impl Default for StreamCollector

fn default() -> StreamCollector

Returns the “default value” for a type.