pub type HandleStream = Arc<dyn Fn(Vec<EventRecord>) -> Result<(), StreamHandlerError> + Send + Sync + 'static>;
pub struct HandleStream { /* private fields */ }