Trait catapult::processor::InputProcessor

pub trait InputProcessor: ConfigurableFilter {
    fn start(&self,
             config: &Option<HashMap<String, String>>)
             -> Receiver<String> { ... }
    fn handle_func(tx: SyncSender<String>,
                   config: Option<HashMap<String, String>>) { ... }
    fn invoke(&self,
              config: &Option<HashMap<String, String>>,
              handle_func: fn(_: SyncSender<String>, _: Option<HashMap<String, String>>))
              -> Receiver<String> { ... }
}

Provided Methods

fn start(&self, config: &Option<HashMap<String, String>>) -> Receiver<String>

fn handle_func(tx: SyncSender<String>, config: Option<HashMap<String, String>>)

fn invoke(&self,
          config: &Option<HashMap<String, String>>,
          handle_func: fn(_: SyncSender<String>, _: Option<HashMap<String, String>>))
          -> Receiver<String>

Implementors

• impl InputProcessor for Stdin
• impl InputProcessor for Random
• impl InputProcessor for Network