Struct PartialJsonParser 

pub struct PartialJsonParser { /* private fields */ }

Streaming structural parser for partial Anthropic SSE tool-input JSON.

Feed each InputJsonDelta string via push. When the result is PrefixState::ValidPrefix with an empty missing_required, the engine may synthesize a ToolCall and speculatively dispatch it.

Examples

use zeph_core::agent::speculative::partial_json::{PartialJsonParser, PrefixState};

let mut p = PartialJsonParser::new();
// Simulate incremental SSE deltas
p.push(r#"{"command": "ls "#);
let state = p.push(r#"-la"}"#);
assert!(matches!(state, PrefixState::ValidPrefix { .. }));

Implementations

impl PartialJsonParser

pub fn new() -> Self

Create a new parser. Call set_required to configure the list of required schema keys before the first push.

pub fn set_required(&mut self, required: Vec<String>)

Set the list of keys required by the tool’s input_schema.

Keys in this list that are absent from the accumulated buffer are reported as missing_required in PrefixState::ValidPrefix.

pub fn push(&mut self, delta: &str) -> PrefixState

Append delta and re-scan the buffer.

Returns the current PrefixState. May be called repeatedly; each call replaces the previous result.

pub fn reset(&mut self)

Reset the parser for reuse after a commit or cancel.

Trait Implementations

impl Default for PartialJsonParser

fn default() -> Self

Returns the “default value” for a type.