Struct streamson_lib::strategy::all::All

pub struct All { /* fields omitted */ }

Trigger handlers on every element

Implementations

impl All

pub fn new() -> Self

Creates a new All

It triggers handlers on all found elements

pub fn set_convert(&mut self, convert: bool)

Sets whether handlers should be actually used to converting data

pub fn add_handler(&mut self, handler: Arc<Mutex<dyn Handler>>)

Adds a handler to All

Arguments

• handler - handler to be triggers when path matches

Example

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

let mut trigger = strategy::All::new();
let handler = handler::Analyser::new();
trigger.add_handler(
    Arc::new(Mutex::new(handler))
);

Trait Implementations

impl Default for All

fn default() -> All

Returns the “default value” for a type.

impl Strategy for All

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