fiddler

Trait InputBatch

Source 
pub trait InputBatch: Closer {
    // Required method
    fn read_batch(&mut self) -> Result<(MessageBatch, CallbackChan), Error>;
}
Expand description

BatchInput module trait to insert one to may crate::Message into the pipeline. InputBatch is currently not yet introduced into the runtime.

Required Methods§

Source

fn read_batch(&mut self) -> Result<(MessageBatch, CallbackChan), Error>

Read multiple messages from the input module and expected return a tuple containing the crate::MessageBatch and a crate::CallbackChan for reporting status back.

Implementors§