summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_interface_asio_test_utils.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/executor/network_interface_asio_test_utils.h')
-rw-r--r--src/mongo/executor/network_interface_asio_test_utils.h33
1 files changed, 16 insertions, 17 deletions
diff --git a/src/mongo/executor/network_interface_asio_test_utils.h b/src/mongo/executor/network_interface_asio_test_utils.h
index bfd489514b0..0c1ff03cf11 100644
--- a/src/mongo/executor/network_interface_asio_test_utils.h
+++ b/src/mongo/executor/network_interface_asio_test_utils.h
@@ -135,23 +135,22 @@ static Deferred<std::vector<T>> collect(std::vector<Deferred<T>>& ds, ThreadPool
collectState->mem.resize(collectState->goal);
for (std::size_t i = 0; i < ds.size(); ++i) {
- ds[i].then(pool,
- [collectState, out, i](T res) mutable {
- // The bool return is unused.
- stdx::lock_guard<stdx::mutex> lk(collectState->mtx);
- collectState->mem[i] = std::move(res);
-
- // If we're done.
- if (collectState->goal == ++collectState->numFinished) {
- std::vector<T> outInitialized;
- outInitialized.reserve(collectState->mem.size());
- for (auto&& mem_entry : collectState->mem) {
- outInitialized.emplace_back(std::move(*mem_entry));
- }
- out.emplace(outInitialized);
- }
- return true;
- });
+ ds[i].then(pool, [collectState, out, i](T res) mutable {
+ // The bool return is unused.
+ stdx::lock_guard<stdx::mutex> lk(collectState->mtx);
+ collectState->mem[i] = std::move(res);
+
+ // If we're done.
+ if (collectState->goal == ++collectState->numFinished) {
+ std::vector<T> outInitialized;
+ outInitialized.reserve(collectState->mem.size());
+ for (auto&& mem_entry : collectState->mem) {
+ outInitialized.emplace_back(std::move(*mem_entry));
+ }
+ out.emplace(outInitialized);
+ }
+ return true;
+ });
}
return out;
}