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 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) -> StreamResult

Finish collecting and return the final result.

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.