Struct streamson_lib::strategy::trigger::Trigger

pub struct Trigger { /* fields omitted */ }

Processes data from input and triggers handlers

Implementations

impl Trigger

pub fn new() -> Self

Creates a new Trigger

It collects matched data and triggers handlers when entire data are read.

pub fn add_matcher(
    &mut self,
    matcher: Box<dyn MatchMaker>,
    handlers: &[Arc<Mutex<dyn Handler>>]
)

Adds a mathcher and a handler to Trigger

Arguments

• matcher - matcher which matches the path
• handlers - list of handlers to be triggers when path matches

Example

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

let mut trigger = strategy::Trigger::new();
let handler = handler::PrintLn::new();
let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
trigger.add_matcher(
    Box::new(matcher),
    &[Arc::new(Mutex::new(handler))]
);

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

Processes input data

Arguments

• input - input data

Returns

• `Ok(()) processing passed, more data might be needed
• Err(_) - error occured during processing

Example

use streamson_lib::strategy;

let mut trigger = strategy::Trigger::new();
trigger.process(br#"{}"#);

Errors

If parsing logic finds that JSON is not valid, it returns error::General.

Note that streamson assumes that its input is a valid JSONs and if not, it still might be processed without an error. This is caused because streamson does not validate JSON.

Trait Implementations

impl Default for Trigger

pub fn default() -> Self

Returns the "default value" for a type.