Struct StreamParser 

pub struct StreamParser { /* private fields */ }

Parser for streaming SSE responses

Handles incremental parsing of tool calls from Server-Sent Events (SSE) streams. Accumulates partial data and emits deltas as they arrive.

Example

let mut parser = StreamParser::new(Provider::Anthropic);

// Process each SSE chunk
for chunk in sse_stream {
    if let Some(delta) = parser.parse_chunk(&chunk)? {
        match delta {
            ToolDelta::Start { name, .. } => println!("Starting: {}", name),
            ToolDelta::Arguments { delta } => print!("{}", delta),
            ToolDelta::End => println!("\nDone!"),
        }
    }
}

// Get the complete tool call
let tool_call = parser.finalize()?;

Implementations

impl StreamParser

pub fn new(provider: Provider) -> Self

Create a new streaming parser for the specified provider

pub fn parse_chunk(&mut self, chunk: &str) -> Result<Option<ToolDelta>>

Parse a single SSE chunk and return any deltas

Returns None if the chunk doesn’t contain relevant tool call data. Returns Some(ToolDelta) when tool call events occur.

pub fn finalize(self) -> Result<ToolCall>

Get the final complete tool call after streaming is done

This should be called after all chunks have been processed.