intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 37 insertions, 0 deletions

diff --git a/library/cpp/messagebus/actor/tasks_ut.cpp b/library/cpp/messagebus/actor/tasks_ut.cpp
new file mode 100644
index 00000000000..d80e8451a50
--- /dev/null
+++ b/library/cpp/messagebus/actor/tasks_ut.cpp
@@ -0,0 +1,37 @@
+#include <library/cpp/testing/unittest/registar.h>
+
+#include "tasks.h"
+
+using namespace NActor;
+
+Y_UNIT_TEST_SUITE(TTasks) {
+    Y_UNIT_TEST(AddTask_FetchTask_Simple) {
+        TTasks tasks;
+
+        UNIT_ASSERT(tasks.AddTask());
+        UNIT_ASSERT(!tasks.AddTask());
+        UNIT_ASSERT(!tasks.AddTask());
+
+        UNIT_ASSERT(tasks.FetchTask());
+        UNIT_ASSERT(!tasks.FetchTask());
+
+        UNIT_ASSERT(tasks.AddTask());
+    }
+
+    Y_UNIT_TEST(AddTask_FetchTask_AddTask) {
+        TTasks tasks;
+
+        UNIT_ASSERT(tasks.AddTask());
+        UNIT_ASSERT(!tasks.AddTask());
+
+        UNIT_ASSERT(tasks.FetchTask());
+        UNIT_ASSERT(!tasks.AddTask());
+        UNIT_ASSERT(tasks.FetchTask());
+        UNIT_ASSERT(!tasks.AddTask());
+        UNIT_ASSERT(!tasks.AddTask());
+        UNIT_ASSERT(tasks.FetchTask());
+        UNIT_ASSERT(!tasks.FetchTask());
+
+        UNIT_ASSERT(tasks.AddTask());
+    }
+}