data_pipeline_rs::data_handler

Trait DataConsumer

source
pub trait DataConsumer<T> {
    // Required method
    fn consume(&mut self, data: T);

    // Provided method
    fn get_stats(&self) -> Option<Value> { ... }
}

Required Methods§

source

fn consume(&mut self, data: T)

Provided Methods§

Implementors§