Struct JsonOutputStream 

pub struct JsonOutputStream { /* private fields */ }

JSON Output Stream class Processes streaming output and emits parsed JSON messages

Implementations

impl JsonOutputStream

pub fn new() -> Self

Create a new JSON output stream processor

pub fn set_on_message<F>(&mut self, callback: F)

where F: Fn(&Value, usize) + 'static,

Set callback for each parsed message

pub fn set_on_error<F>(&mut self, callback: F)

where F: Fn(&ParseError) + 'static,

Set callback for parse errors

pub fn set_on_raw_line<F>(&mut self, callback: F)

where F: Fn(&str, usize) + 'static,

Set callback for each raw line

pub fn process(&mut self, chunk: &str) -> Vec<Value>

Process a chunk of output data

Arguments

• chunk - Data chunk to process

Returns

Vector of messages parsed from this chunk

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

Flush any remaining data in the buffer

Returns

Vector of messages from flushed buffer

pub fn get_messages(&self) -> &[Value]

Get all collected messages

pub fn get_errors(&self) -> &[ParseError]

Get all parse errors

pub fn reset(&mut self)

Reset the stream processor

pub fn filter_by_type(&self, msg_type: &str) -> Vec<&Value>

Filter messages by type

Arguments

• msg_type - Message type to filter

pub fn find<F>(&self, predicate: F) -> Option<&Value>

where F: Fn(&Value) -> bool,

Find first message matching a predicate

Arguments

• predicate - Filter function

Trait Implementations

impl Debug for JsonOutputStream

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

Formats the value using the given formatter.

impl Default for JsonOutputStream

fn default() -> Self

Returns the “default value” for a type.