### Unit Test API ###
| 200 | |
| 201 | // ### Unit Test API ### |
| 202 | void DeliverBatches(bool slow, const std::vector<MockScanTask>& to_deliver) { |
| 203 | for (MockScanTask task : to_deliver) { |
| 204 | if (slow) { |
| 205 | std::ignore = SleepABitAsync().Then( |
| 206 | [task]() mutable { task.batch_future.MarkFinished(task.batch); }); |
| 207 | } else { |
| 208 | task.batch_future.MarkFinished(task.batch); |
| 209 | } |
| 210 | } |
| 211 | } |
| 212 | |
| 213 | void DeliverBatchesInOrder(bool slow) { DeliverBatches(slow, scan_tasks_); } |
| 214 |
nothing calls this directly
no test coverage detected