Struct Convert 

pub struct Convert { /* private fields */ }

Processes data from input and triggers handler

Implementations

impl Convert

pub fn new() -> Self

Creates a new Convert

It should replace a parts of the JSON using custom bytes data are read.

pub fn add_matcher( &mut self, matcher: Box<dyn Matcher>, handler: Arc<Mutex<dyn Handler>>, )

Adds a mathcher and a handler to Convert

Arguments

• matcher - matcher which matches the path
• handlers - funtions which should be run to convert the data

Example

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

let mut convert = strategy::Convert::new();

let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
convert.add_matcher(
    Box::new(matcher),
    Arc::new(Mutex::new(handler::Replace::new(vec![b'"', b'*', b'*', b'*', b'"']))),
);

Trait Implementations

impl Default for Convert

fn default() -> Self

Returns the “default value” for a type.

impl Strategy for Convert

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