aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2024-03-25 11:05:15 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2024-03-25 11:12:04 +0300
commitb1419227132ab31b12bcb2f2d06bf4bde67a7295 (patch)
tree6fc0c1e3925a23d231c17dedbed301cbed7f0c5a
parentb2b8b2195825882c94e71bcb70a7bfafc228ac8f (diff)
downloadydb-b1419227132ab31b12bcb2f2d06bf4bde67a7295.tar.gz
Intermediate changes
-rw-r--r--yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp13
1 files changed, 9 insertions, 4 deletions
diff --git a/yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp b/yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp
index 47269a7523..17eb4fe4cc 100644
--- a/yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp
+++ b/yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp
@@ -32,8 +32,11 @@ protected:
TDelayedExecutor::WaitForDuration(RandomDuration(TDuration::MilliSeconds(15)));
}
- void EnsureRunning() {
- WaitFor(BIND([] {}).AsyncVia(Invoker_).Run()).ThrowOnError();
+ void EnsureRunning()
+ {
+ WaitFor(BIND([] {})
+ .AsyncVia(Invoker_).Run())
+ .ThrowOnError();
}
struct TLooper
@@ -50,11 +53,13 @@ protected:
});
}
- void Start() {
+ void Start()
+ {
Invoker->Invoke(MakeCallback());
}
- TFuture<void> Stop() {
+ TFuture<void> Stop()
+ {
StopPromise = NewPromise<void>();
StopRespawning->store(true);
return StopPromise.ToFuture();