| 230 | // internal state gets updated on each call. |
| 231 | template <typename... Args> |
| 232 | AsyncGenerator<ChunkedBlock> MakeChunkingGenerator( |
| 233 | AsyncGenerator<std::shared_ptr<Buffer>> source, Args&&... args) { |
| 234 | return MakeTransformedGenerator(std::move(source), |
| 235 | ChunkingTransformer::Make(std::forward<Args>(args)...)); |
| 236 | } |
| 237 | |
| 238 | class TableReaderImpl : public TableReader, |
| 239 | public std::enable_shared_from_this<TableReaderImpl> { |
no test coverage detected