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

Method MakeSource

cpp/src/arrow/util/async_generator_test.cc:195–202  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

193
194 protected:
195 AsyncGenerator<TestInt> MakeSource(const std::vector<TestInt>& items) {
196 std::vector<TestInt> wrapped(items.begin(), items.end());
197 auto gen = util::AsyncVectorIt(std::move(wrapped));
198 if (IsSlow()) {
199 return util::SlowdownABit(std::move(gen));
200 }
201 return gen;
202 }
203
204 AsyncGenerator<TestInt> MakeEmptySource() { return MakeSource({}); }
205

Callers

nothing calls this directly

Calls 4

AsyncVectorItFunction · 0.85
SlowdownABitFunction · 0.85
beginMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected