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

Adds a mathcher and a handler to Trigger

Arguments

• matcher - matcher which matches the path
• handler - handler to be triggers when path matches

Example

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

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

Trait Implementations

impl Default for Trigger

fn default() -> Self

Returns the “default value” for a type.

impl Strategy for Trigger

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