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

Function MakeSequencingGenerator

cpp/src/arrow/util/async_generator.h:437–443  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

435/// insertion into a priority queue.
436template <typename T, typename ComesAfter, typename IsNext>
437AsyncGenerator<T> MakeSequencingGenerator(AsyncGenerator<T> source_generator,
438 ComesAfter compare, IsNext is_next,
439 T initial_value) {
440 return SequencingGenerator<T, ComesAfter, IsNext>(
441 std::move(source_generator), std::move(compare), std::move(is_next),
442 std::move(initial_value));
443}
444
445/// \see MakeTransformedGenerator
446template <typename T, typename V>

Callers 3

ScanBatchesAsyncMethod · 0.85
MakeOrderedSinkNodeFunction · 0.85
TEST_PFunction · 0.85

Calls

no outgoing calls

Tested by 1

TEST_PFunction · 0.68