Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.

1 files changed, 24 insertions, 24 deletions

diff --git a/library/cpp/threading/future/async_ut.cpp b/library/cpp/threading/future/async_ut.cpp
index a3699744e4..a452965dbc 100644
--- a/library/cpp/threading/future/async_ut.cpp
+++ b/library/cpp/threading/future/async_ut.cpp
@@ -6,13 +6,13 @@
 #include <util/generic/vector.h>
 
 namespace {
-    struct TMySuperTaskQueue {
-    };
+    struct TMySuperTaskQueue { 
+    }; 
 
 }
 
 namespace NThreading {
-    /* Here we provide an Async overload for TMySuperTaskQueue indide NThreading namespace
+    /* Here we provide an Async overload for TMySuperTaskQueue indide NThreading namespace 
  * so that we can call it in the way
  *
  * TMySuperTaskQueue queue;
@@ -20,38 +20,38 @@ namespace NThreading {
  *
  * See also ExtensionExample unittest.
  */
-    template <typename Func>
-    TFuture<TFunctionResult<Func>> Async(Func func, TMySuperTaskQueue&) {
-        return MakeFuture(func());
-    }
+    template <typename Func> 
+    TFuture<TFunctionResult<Func>> Async(Func func, TMySuperTaskQueue&) { 
+        return MakeFuture(func()); 
+    } 
 
 }
 
 Y_UNIT_TEST_SUITE(Async) {
     Y_UNIT_TEST(ExtensionExample) {
-        TMySuperTaskQueue queue;
-        auto future = NThreading::Async([]() { return 5; }, queue);
-        future.Wait();
-        UNIT_ASSERT_VALUES_EQUAL(future.GetValue(), 5);
-    }
+        TMySuperTaskQueue queue; 
+        auto future = NThreading::Async([]() { return 5; }, queue); 
+        future.Wait(); 
+        UNIT_ASSERT_VALUES_EQUAL(future.GetValue(), 5); 
+    } 
 
     Y_UNIT_TEST(WorksWithIMtpQueue) {
         auto queue = MakeHolder<TThreadPool>();
-        queue->Start(1);
+        queue->Start(1); 
 
-        auto future = NThreading::Async([]() { return 5; }, *queue);
-        future.Wait();
-        UNIT_ASSERT_VALUES_EQUAL(future.GetValue(), 5);
-    }
+        auto future = NThreading::Async([]() { return 5; }, *queue); 
+        future.Wait(); 
+        UNIT_ASSERT_VALUES_EQUAL(future.GetValue(), 5); 
+    } 
 
     Y_UNIT_TEST(ProperlyDeducesFutureType) {
-        // Compileability test
+        // Compileability test 
         auto queue = CreateThreadPool(1);
 
-        NThreading::TFuture<void> f1 = NThreading::Async([]() {}, *queue);
-        NThreading::TFuture<int> f2 = NThreading::Async([]() { return 5; }, *queue);
-        NThreading::TFuture<double> f3 = NThreading::Async([]() { return 5.0; }, *queue);
-        NThreading::TFuture<TVector<int>> f4 = NThreading::Async([]() { return TVector<int>(); }, *queue);
-        NThreading::TFuture<int> f5 = NThreading::Async([]() { return NThreading::MakeFuture(5); }, *queue);
-    }
+        NThreading::TFuture<void> f1 = NThreading::Async([]() {}, *queue); 
+        NThreading::TFuture<int> f2 = NThreading::Async([]() { return 5; }, *queue); 
+        NThreading::TFuture<double> f3 = NThreading::Async([]() { return 5.0; }, *queue); 
+        NThreading::TFuture<TVector<int>> f4 = NThreading::Async([]() { return TVector<int>(); }, *queue); 
+        NThreading::TFuture<int> f5 = NThreading::Async([]() { return NThreading::MakeFuture(5); }, *queue); 
+    } 
 }