Skip to main content

Strategy

streamson_lib::strategy

Trait Strategy 

Source 
pub trait Strategy {
    // Required methods
    fn process(&mut self, input: &[u8]) -> Result<Vec<Output>, General>;
    fn terminate(&mut self) -> Result<Vec<Output>, General>;
}

Required Methods§

Source

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

Processes input data

§Arguments
  • input - input data
§Returns
  • `Ok(_) processing passed
  • Err(_) - error occured during processing
§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.

Source

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

Should be called when input data terminates

§Returns
  • `Ok(_) processing passed
  • Err(_) - error occured during processing
§Errors

Should return an error if strategy is in unterminated state (still expects data in input)

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§