pub trait HasNextBatch { // Required method fn has_next_batch(&self) -> Option<(Vec<u8>, Vec<u8>)>; }