| 482 | } |
| 483 | |
| 484 | AsyncGenerator<std::shared_ptr<RecordBatch>> MakeGenerator( |
| 485 | std::shared_ptr<StreamingReader> reader) { |
| 486 | return [reader = std::move(reader)] { return reader->ReadNextAsync(); }; |
| 487 | } |
| 488 | template <typename... Args> |
| 489 | Result<AsyncGenerator<std::shared_ptr<RecordBatch>>> MakeGenerator(Args&&... args) { |
| 490 | ARROW_ASSIGN_OR_RAISE(auto reader, MakeReader(std::forward<Args>(args)...)); |
nothing calls this directly
no test coverage detected