| 871 | int64_t bytes_read() const override { return bytes_decoded_->load(); } |
| 872 | |
| 873 | Status ReadNext(std::shared_ptr<RecordBatch>* batch) override { |
| 874 | auto next_fut = ReadNextAsync(); |
| 875 | auto next_result = next_fut.result(); |
| 876 | return std::move(next_result).Value(batch); |
| 877 | } |
| 878 | |
| 879 | Future<std::shared_ptr<RecordBatch>> ReadNextAsync() override { |
| 880 | return record_batch_gen_(); |