MCPcopy Create free account
hub / github.com/apache/arrow / MakeGenerator

Method MakeGenerator

cpp/src/arrow/json/reader_test.cc:462–465  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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)...));

Callers

nothing calls this directly

Calls 1

ReadNextAsyncMethod · 0.45

Tested by

no test coverage detected