pub trait EventHandler<T>: Send + Sync { // Required method fn on_event(&self, event: &T, sequence: u64, end_of_batch: bool); }
Event Handler trait.
Called when an event is available for processing.