Function gqlog::filter_stream

pub fn filter_stream<'de, R>(query: String, reader: R, func: fn(_: Value)) where
    R: Read<'de>, 

Filter a stream of JSON objects and trigger the callback for each.

Examples

extern crate serde_json;
extern crate gqlog;

use serde_json::de::{ StrRead };

fn main() {
    let query = String::from("{ foo }");
    let data = r#"{
        "foo": "bar",
        "baz": "buz"
    }"#;
    let reader = StrRead::new(data);

    gqlog::filter_stream::<StrRead>(query, reader, |value| {
        println!("{}", value.to_string());
    });
}