| 100 | } |
| 101 | |
| 102 | static AsyncGenerator<std::shared_ptr<Buffer>> MakeAsync( |
| 103 | AsyncGenerator<std::shared_ptr<Buffer>> buffer_iterator) { |
| 104 | Transformer<std::shared_ptr<Buffer>, std::shared_ptr<Buffer>> fn = |
| 105 | CSVBufferIterator(); |
| 106 | return MakeTransformedGenerator(std::move(buffer_iterator), fn); |
| 107 | } |
| 108 | |
| 109 | Result<TransformFlow<std::shared_ptr<Buffer>>> operator()(std::shared_ptr<Buffer> buf) { |
| 110 | if (buf == nullptr) { |
nothing calls this directly
no test coverage detected