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

Method MakeAsync

cpp/src/arrow/csv/reader.cc:102–107  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

100 }
101
102 static AsyncGenerator<std::shared_ptr<Buffer>> MakeAsync(
103 AsyncGenerator<std::shared_ptr<Buffer>> buffer_iterator) {
104 Transformer<std::shared_ptr<Buffer>, std::shared_ptr<Buffer>> fn =
105 CSVBufferIterator();
106 return MakeTransformedGenerator(std::move(buffer_iterator), fn);
107 }
108
109 Result<TransformFlow<std::shared_ptr<Buffer>>> operator()(std::shared_ptr<Buffer> buf) {
110 if (buf == nullptr) {

Callers

nothing calls this directly

Calls 2

CSVBufferIteratorClass · 0.85
MakeTransformedGeneratorFunction · 0.85

Tested by

no test coverage detected