Struct ToolCallExtractor 

pub struct ToolCallExtractor { /* private fields */ }

Streaming state machine that detects <tool_call> blocks in text deltas and converts them into NormalizedEvent tool call events.

Usage

Create one extractor per streaming response. Feed each text delta through process_delta, and call flush when the stream ends.

Implementations

impl ToolCallExtractor

pub fn new() -> Self

Create a new extractor in the initial text state.

pub fn process_delta(&mut self, text: &str) -> Vec<NormalizedEvent>

Process a text delta and return zero or more normalized events.

In Text state, emits MessageDelta for regular text and transitions to InToolCallTag when <tool_call> is detected.

In InToolCallTag state, buffers content and emits ToolCallDelta events. When </tool_call> is detected, parses the JSON and emits ToolCallComplete (or Error on parse failure), then transitions back to Text.

pub fn flush(&mut self) -> Vec<NormalizedEvent>

Flush any remaining state at the end of the stream.

If we are mid-tag, emits an error event. If there is buffered partial tag text that turned out to not be a tag, emits it as a MessageDelta.

Trait Implementations

impl Debug for ToolCallExtractor

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

Formats the value using the given formatter.

impl Default for ToolCallExtractor

fn default() -> Self

Returns the “default value” for a type.