Crate streamson_lib

This library is able to split JSON into separate parts.

It can have various matchers which matches the path (see matcher)

And various handlers to do something with found data (see handlers)

Example

use streamson_lib::{handler::{self, Handler}, matcher, Collector};
use std::sync::{Arc, Mutex};

let file_handler = Arc::new(
    Mutex::new(handler::File::new("/tmp/out.txt").unwrap())
);
let stdout_handler = Arc::new(Mutex::new(handler::PrintLn::new()));

let first_matcher = matcher::Simple::new(r#"{"users"}[]"#);
let second_matcher = matcher::Simple::new(r#"{"groups"}[]"#);

let mut collector = Collector::new();

for input in vec![
    br#"{"users": [1,2]"#.to_vec(),
    br#", "groups": [3, 4]}"#.to_vec(),
] {
    collector.process(&input).unwrap();
}
collector = collector.add_matcher(
    Box::new(first_matcher),
    &[stdout_handler.clone(), file_handler],
);

collector = collector.add_matcher(
    Box::new(second_matcher),
    &[stdout_handler],
);

Re-exports

pub use collector::Collector;

pub use handler::Handler;

pub use matcher::MatchMaker;

pub use matcher::Simple;

pub use path::Emitter;

pub use path::Output;

Modules

collector	The main logic of JSON processing
error	Module containing errors
handler	Collections of handler (what to do with matched paths and data).
matcher
path	Emits paths with indexes from input data