| 1975 | }; |
| 1976 | |
| 1977 | Future<SelectiveIpcFileRecordBatchGenerator::Item> |
| 1978 | SelectiveIpcFileRecordBatchGenerator::operator()() { |
| 1979 | int index = index_++; |
| 1980 | if (index >= state_->num_record_batches()) { |
| 1981 | return IterationEnd<SelectiveIpcFileRecordBatchGenerator::Item>(); |
| 1982 | } |
| 1983 | return state_->ReadRecordBatchAsync(index); |
| 1984 | } |
| 1985 | |
| 1986 | Future<WholeIpcFileRecordBatchGenerator::Item> |
| 1987 | WholeIpcFileRecordBatchGenerator::operator()() { |
nothing calls this directly
no test coverage detected