aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/future/wait/wait.cpp
diff options
context:
space:
mode:
authorNikita Petrenko <npetrenko97@gmail.com>2022-02-10 16:50:57 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:57 +0300
commitfd3f62e99d2990dd93788742aaf6a9bd5cb4d5a3 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/threading/future/wait/wait.cpp
parentaa72317474c8df5627f69271ae16f4237e5d3612 (diff)
downloadydb-fd3f62e99d2990dd93788742aaf6a9bd5cb4d5a3.tar.gz
Restoring authorship annotation for Nikita Petrenko <npetrenko97@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/future/wait/wait.cpp')
-rw-r--r--library/cpp/threading/future/wait/wait.cpp38
1 files changed, 19 insertions, 19 deletions
diff --git a/library/cpp/threading/future/wait/wait.cpp b/library/cpp/threading/future/wait/wait.cpp
index 8ff1997a2b..a173833a7f 100644
--- a/library/cpp/threading/future/wait/wait.cpp
+++ b/library/cpp/threading/future/wait/wait.cpp
@@ -1,40 +1,40 @@
#include "wait.h"
-#include "wait_group.h"
-#include "wait_policy.h"
-
+#include "wait_group.h"
+#include "wait_policy.h"
+
namespace NThreading {
namespace {
- template <class WaitPolicy>
+ template <class WaitPolicy>
TFuture<void> WaitGeneric(const TFuture<void>& f1) {
- return f1;
- }
+ return f1;
+ }
- template <class WaitPolicy>
+ template <class WaitPolicy>
TFuture<void> WaitGeneric(const TFuture<void>& f1, const TFuture<void>& f2) {
- TWaitGroup<WaitPolicy> wg;
+ TWaitGroup<WaitPolicy> wg;
- wg.Add(f1).Add(f2);
+ wg.Add(f1).Add(f2);
- return std::move(wg).Finish();
- }
+ return std::move(wg).Finish();
+ }
template <class WaitPolicy>
TFuture<void> WaitGeneric(TArrayRef<const TFuture<void>> futures) {
- if (futures.empty()) {
- return MakeFuture();
+ if (futures.empty()) {
+ return MakeFuture();
}
- if (futures.size() == 1) {
+ if (futures.size() == 1) {
return futures.front();
}
- TWaitGroup<WaitPolicy> wg;
- for (const auto& fut : futures) {
- wg.Add(fut);
+ TWaitGroup<WaitPolicy> wg;
+ for (const auto& fut : futures) {
+ wg.Add(fut);
}
- return std::move(wg).Finish();
- }
+ return std::move(wg).Finish();
+ }
}
////////////////////////////////////////////////////////////////////////////////