pub trait NewDataHandler: Send + Sync { // Required method fn handle_event(&self, value: &StreamingEvent); }