| 279 | void FinishScanBegin() { fragment_scanner_future_.MarkFinished(fragment_scanner_); } |
| 280 | |
| 281 | Future<> DeliverInit(bool slow) { |
| 282 | if (slow) { |
| 283 | return SleepABitAsync().Then([this] { |
| 284 | FinishInspection(); |
| 285 | return SleepABitAsync().Then([this] { FinishScanBegin(); }); |
| 286 | }); |
| 287 | } else { |
| 288 | FinishInspection(); |
| 289 | FinishScanBegin(); |
| 290 | return Future<>::MakeFinished(); |
| 291 | } |
| 292 | } |
| 293 | |
| 294 | void DeliverBatchesInOrder(bool slow) { |
| 295 | std::ignore = DeliverInit(slow).Then( |
nothing calls this directly
no test coverage detected