| 460 | } |
| 461 | |
| 462 | AsyncGenerator<std::shared_ptr<RecordBatch>> MakeGenerator( |
| 463 | std::shared_ptr<StreamingReader> reader) { |
| 464 | return [reader = std::move(reader)] { return reader->ReadNextAsync(); }; |
| 465 | } |
| 466 | template <typename... Args> |
| 467 | Result<AsyncGenerator<std::shared_ptr<RecordBatch>>> MakeGenerator(Args&&... args) { |
| 468 | ARROW_ASSIGN_OR_RAISE(auto reader, MakeReader(std::forward<Args>(args)...)); |
nothing calls this directly
no test coverage detected