| 1988 | } |
| 1989 | |
| 1990 | int TotalBatchesRead() { |
| 1991 | int sum = 0; |
| 1992 | for (const auto& controlled_fragment : controlled_fragments_) { |
| 1993 | sum += controlled_fragment->NumBatchesRead(); |
| 1994 | } |
| 1995 | return sum; |
| 1996 | } |
| 1997 | |
| 1998 | template <typename T> |
| 1999 | void Finish(AsyncGenerator<T> gen) { |
nothing calls this directly
no test coverage detected