Function TEST

cpp/src/arrow/util/thread_pool_test.cc:268–279

                         ::testing::Values(false, true));

TEST(SerialExecutor, AsyncGenerator) {
  std::vector<TestInt> values{1, 2, 3, 4, 5};
  auto source = util::SlowdownABit(util::AsyncVectorIt(values));
  Iterator<TestInt> iter =
      SerialExecutor::IterateGenerator<TestInt>([&source](Executor* executor) {
        return MakeMappedGenerator(source, [executor](const TestInt& ti) {
          return DeferNotOk(executor->Submit([ti] { return ti; }));
        });
      });
  ASSERT_OK_AND_ASSIGN(auto vec, iter.ToVector());
  ASSERT_EQ(vec, values);
}

TEST(SerialExecutor, AsyncGeneratorWithFollowUp) {
  // Sometimes a task will generate follow-up tasks.  These should be run