Function process 

pub fn process<E, F>(cb: F) -> !
where
    E: Debug,
    F: Fn(WriteEvent<'_>, &mut RecordWriter<'_>) -> Result<(), E>,