summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/future/future_ut.cpp
diff options
context:
space:
mode:
authorIlnur Khuziev <[email protected]>2022-02-10 16:46:13 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:13 +0300
commit736dcd8ca259457a136f2f9f9168c44643914323 (patch)
treeddd46a036d68bfa83aa11b892f31243ea6b068a1 /library/cpp/threading/future/future_ut.cpp
parent9bf2fa2b060c9881d3135c2208c624a1dd546ecc (diff)
Restoring authorship annotation for Ilnur Khuziev <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/future/future_ut.cpp')
-rw-r--r--library/cpp/threading/future/future_ut.cpp72
1 files changed, 36 insertions, 36 deletions
diff --git a/library/cpp/threading/future/future_ut.cpp b/library/cpp/threading/future/future_ut.cpp
index 05950a568d4..2068337f4ea 100644
--- a/library/cpp/threading/future/future_ut.cpp
+++ b/library/cpp/threading/future/future_ut.cpp
@@ -1,6 +1,6 @@
#include "future.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <list>
#include <type_traits>
@@ -293,23 +293,23 @@ namespace {
}
Y_UNIT_TEST(ShouldWaitExceptionOrAllVectorWithValueType) {
- TPromise<int> promise1 = NewPromise<int>();
- TPromise<int> promise2 = NewPromise<int>();
-
- TVector<TFuture<int>> promises;
- promises.push_back(promise1);
- promises.push_back(promise2);
-
+ TPromise<int> promise1 = NewPromise<int>();
+ TPromise<int> promise2 = NewPromise<int>();
+
+ TVector<TFuture<int>> promises;
+ promises.push_back(promise1);
+ promises.push_back(promise2);
+
TFuture<void> future = WaitExceptionOrAll(promises);
- UNIT_ASSERT(!future.HasValue());
-
- promise1.SetValue(0);
- UNIT_ASSERT(!future.HasValue());
-
- promise2.SetValue(0);
- UNIT_ASSERT(future.HasValue());
- }
-
+ UNIT_ASSERT(!future.HasValue());
+
+ promise1.SetValue(0);
+ UNIT_ASSERT(!future.HasValue());
+
+ promise2.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+ }
+
Y_UNIT_TEST(ShouldWaitExceptionOrAllList) {
TPromise<void> promise1 = NewPromise();
TPromise<void> promise2 = NewPromise();
@@ -353,25 +353,25 @@ namespace {
UNIT_ASSERT(future.HasValue());
}
-
- Y_UNIT_TEST(ShouldWaitAnyVectorWithValueType) {
- TPromise<int> promise1 = NewPromise<int>();
- TPromise<int> promise2 = NewPromise<int>();
-
- TVector<TFuture<int>> promises;
- promises.push_back(promise1);
- promises.push_back(promise2);
-
- TFuture<void> future = WaitAny(promises);
- UNIT_ASSERT(!future.HasValue());
-
- promise1.SetValue(0);
- UNIT_ASSERT(future.HasValue());
-
- promise2.SetValue(0);
- UNIT_ASSERT(future.HasValue());
- }
-
+
+ Y_UNIT_TEST(ShouldWaitAnyVectorWithValueType) {
+ TPromise<int> promise1 = NewPromise<int>();
+ TPromise<int> promise2 = NewPromise<int>();
+
+ TVector<TFuture<int>> promises;
+ promises.push_back(promise1);
+ promises.push_back(promise2);
+
+ TFuture<void> future = WaitAny(promises);
+ UNIT_ASSERT(!future.HasValue());
+
+ promise1.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+
+ promise2.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+ }
+
Y_UNIT_TEST(ShouldWaitAnyList) {
TPromise<void> promise1 = NewPromise();
TPromise<void> promise2 = NewPromise();