Struct StreamingJsonParser 

pub struct StreamingJsonParser<T> { /* private fields */ }

Parses JSON objects of type T from a stream of text chunks.

It scans for objects inside a JSON array (by default) and yields each fully-formed object as soon as braces are balanced. Useful when an LLM streams a JSON plan and you want to display / process steps incrementally.

Implementations

impl<T> StreamingJsonParser<T>

where T: DeserializeOwned + Clone,

pub fn new() -> StreamingJsonParser<T>

pub fn with_key(self, key: impl Into<String>) -> StreamingJsonParser<T>

Set the array key to look for. e.g. with_key("steps") will look for "steps":[...] in the JSON.

pub fn process_chunk(&mut self, chunk: &str) -> Vec<T>

Append a new chunk and return any newly parsed items.

pub fn accumulated(&self) -> &[T]

Return all accumulated items so far.

pub fn into_buffer(self) -> String

Consume parser and return the full raw text.

Trait Implementations

impl<T> Debug for StreamingJsonParser<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Default for StreamingJsonParser<T>

where T: DeserializeOwned + Clone,

fn default() -> StreamingJsonParser<T>

Returns the “default value” for a type.