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 Matcher>,
    handler: Option<Arc<Mutex<dyn Handler>>>
)

Adds new matcher into filtering

Arguments

• matcher - matcher which matches the path
• handler - optinal handler to be used to process data

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),
    None,
);

Trait Implementations

impl Default for Filter

fn default() -> Self

Returns the “default value” for a type.

impl Strategy for Filter

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

Processes input data

fn terminate(&mut self) -> Result<Vec<Output>, General>

Should be called when input data terminates