Restoring authorship annotation for <lexeyo@yandex-team.ru>. Commit 2 of 2.

1 files changed, 26 insertions, 26 deletions

diff --git a/library/cpp/threading/future/subscription/wait_ut_common.cpp b/library/cpp/threading/future/subscription/wait_ut_common.cpp
index 35a6121bb9..9f961e7303 100644
--- a/library/cpp/threading/future/subscription/wait_ut_common.cpp
+++ b/library/cpp/threading/future/subscription/wait_ut_common.cpp
@@ -1,26 +1,26 @@
-#include "wait_ut_common.h" 
- 
-#include <util/random/shuffle.h> 
-#include <util/system/event.h> 
-#include <util/thread/pool.h> 
- 
-namespace NThreading::NTest::NPrivate { 
- 
-void ExecuteAndWait(TVector<std::function<void()>> jobs, TFuture<void> waiter, size_t threads) { 
-    Y_ENSURE(threads > 0); 
-    Shuffle(jobs.begin(), jobs.end()); 
-    auto pool = CreateThreadPool(threads); 
-    TManualEvent start; 
-    for (auto& j : jobs) { 
-        pool->SafeAddFunc( 
-                        [&start, job = std::move(j)]() { 
-                            start.WaitI(); 
-                            job(); 
-                        }); 
-    } 
-    start.Signal(); 
-    waiter.Wait(); 
-    pool->Stop(); 
-} 
- 
-} 
+#include "wait_ut_common.h"
+
+#include <util/random/shuffle.h>
+#include <util/system/event.h>
+#include <util/thread/pool.h>
+
+namespace NThreading::NTest::NPrivate {
+
+void ExecuteAndWait(TVector<std::function<void()>> jobs, TFuture<void> waiter, size_t threads) {
+    Y_ENSURE(threads > 0);
+    Shuffle(jobs.begin(), jobs.end());
+    auto pool = CreateThreadPool(threads);
+    TManualEvent start;
+    for (auto& j : jobs) {
+        pool->SafeAddFunc(
+                        [&start, job = std::move(j)]() {
+                            start.WaitI();
+                            job();
+                        });
+    }
+    start.Signal();
+    waiter.Wait();
+    pool->Stop();
+}
+
+}