(&mut self)
| 1463 | type Item = Result<RecordBatch, ArrowError>; |
| 1464 | |
| 1465 | fn next(&mut self) -> Option<Self::Item> { |
| 1466 | // get current block |
| 1467 | if self.current_block < self.total_blocks { |
| 1468 | self.maybe_next().transpose() |
| 1469 | } else { |
| 1470 | None |
| 1471 | } |
| 1472 | } |
| 1473 | } |
| 1474 | |
| 1475 | impl<R: Read + Seek> RecordBatchReader for FileReader<R> { |