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

Function MakeEnumeratedGenerator

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

Source from the content-addressed store, hash-verified

1569/// This generator buffers one item (so it knows which item is the last item)
1570template <typename T>
1571AsyncGenerator<Enumerated<T>> MakeEnumeratedGenerator(AsyncGenerator<T> source) {
1572 return FutureFirstGenerator<Enumerated<T>>(
1573 source().Then([source](const T& initial_value) -> AsyncGenerator<Enumerated<T>> {
1574 return EnumeratingGenerator<T>(std::move(source), initial_value);
1575 }));
1576}
1577
1578/// \see MakeTransferredGenerator
1579template <typename T>

Callers 3

FragmentToBatchesFunction · 0.85
FragmentsToBatchesFunction · 0.85
TEST_PFunction · 0.85

Calls 1

ThenMethod · 0.80

Tested by 1

TEST_PFunction · 0.68