| 236 | } |
| 237 | |
| 238 | Status Process(ExecBatch batch) override { |
| 239 | producer_.Push(std::move(batch)); |
| 240 | |
| 241 | if (input_counter_.Increment()) { |
| 242 | return Finish(); |
| 243 | } |
| 244 | return Status::OK(); |
| 245 | } |
| 246 | |
| 247 | Status InputFinished(ExecNode* input, int total_batches) override { |
| 248 | if (input_counter_.SetTotal(total_batches)) { |
no test coverage detected