type NextBatch = Shared<BoxFuture<'static, Result<Option<RecordBatch>, Arc<Error>>>>;
struct NextBatch { /* private fields */ }