| 1997 | |
| 1998 | template <typename T> |
| 1999 | void Finish(AsyncGenerator<T> gen) { |
| 2000 | for (const auto& controlled_fragment : controlled_fragments_) { |
| 2001 | controlled_fragment->Finish(); |
| 2002 | } |
| 2003 | ASSERT_FINISHES_OK(VisitAsyncGenerator(gen, [](T batch) { return Status::OK(); })); |
| 2004 | } |
| 2005 | |
| 2006 | std::shared_ptr<Schema> schema_ = schema({field("values", int32())}); |
| 2007 | std::vector<std::shared_ptr<ControlledFragment>> controlled_fragments_; |
no test coverage detected