Struct streamson_lib::strategy::filter::Filter

pub struct Filter { /* fields omitted */ }

Processes data from input and remove matched parts (and keeps the json valid)

Implementations

impl Filter

pub fn new() -> Self

Create new filter

It removes matched parts of the input

pub fn add_matcher(&mut self, matcher: Box<dyn MatchMaker>)

Adds new matcher into filtering

Arguments

• matcher - matcher which matches the path

Example

use streamson_lib::{strategy, matcher};
use std::sync::{Arc, Mutex};

let mut filter = strategy::Filter::new();
let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
filter.add_matcher(
    Box::new(matcher),
);

pub fn process(&mut self, input: &[u8]) -> Result<Vec<u8>, General>

Processes input data

Returns

• `Ok(_) processing passed, more data might be needed
• Err(_) when input is not correct json

Errors

• Error is triggered when incorrect json is detected Note that not all json errors are detected

Trait Implementations

impl Default for Filter

pub fn default() -> Self

Returns the "default value" for a type.