| 101 | : schema_(std::move(schema)), delegate_(std::move(delegate)) {} |
| 102 | |
| 103 | std::shared_ptr<Schema> schema() const override { return schema_; } |
| 104 | Status ReadNext(std::shared_ptr<RecordBatch>* batch) override { |
| 105 | ARROW_ASSIGN_OR_RAISE(auto next, delegate_.Next()); |
| 106 | if (IsIterationEnd(next)) { |
no outgoing calls