| 127 | } |
| 128 | |
| 129 | void SetFinishedDeferred(std::vector<std::pair<int, bool>> pairs) { |
| 130 | std::this_thread::sleep_for(kYieldDuration); |
| 131 | ABORT_NOT_OK( |
| 132 | pool_->Spawn([this, pairs = std::move(pairs)]() { SetFinished(pairs); })); |
| 133 | } |
| 134 | |
| 135 | // Mark future successful |
| 136 | void SetFinished(int fut_index) { futures_[fut_index].MarkFinished(T(fut_index)); } |
no outgoing calls
no test coverage detected