| 1964 | }; |
| 1965 | |
| 1966 | Future<SelectiveIpcFileRecordBatchGenerator::Item> |
| 1967 | SelectiveIpcFileRecordBatchGenerator::operator()() { |
| 1968 | int index = index_++; |
| 1969 | if (index >= state_->num_record_batches()) { |
| 1970 | return IterationEnd<SelectiveIpcFileRecordBatchGenerator::Item>(); |
| 1971 | } |
| 1972 | return state_->ReadRecordBatchAsync(index); |
| 1973 | } |
| 1974 | |
| 1975 | Future<WholeIpcFileRecordBatchGenerator::Item> |
| 1976 | WholeIpcFileRecordBatchGenerator::operator()() { |
nothing calls this directly
no test coverage detected