diff options
author | robot-piglet <robot-piglet@yandex-team.com> | 2024-03-25 11:05:15 +0300 |
---|---|---|
committer | robot-piglet <robot-piglet@yandex-team.com> | 2024-03-25 11:12:04 +0300 |
commit | b1419227132ab31b12bcb2f2d06bf4bde67a7295 (patch) | |
tree | 6fc0c1e3925a23d231c17dedbed301cbed7f0c5a | |
parent | b2b8b2195825882c94e71bcb70a7bfafc228ac8f (diff) | |
download | ydb-b1419227132ab31b12bcb2f2d06bf4bde67a7295.tar.gz |
Intermediate changes
-rw-r--r-- | yt/yt/core/concurrency/unittests/suspendable_action_queue_ut.cpp | 13 |
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(); |