aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2023-03-10 11:47:56 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2023-03-10 11:47:56 +0300
commitba3d1b1ab159500a4041d437a0aad8d69394b430 (patch)
tree3b3295a8dcae705b3027573ab250ee496a19e427 /library/cpp
parent1a8200d9f6b290ba0ee3dc629ec400ba281be75f (diff)
downloadydb-ba3d1b1ab159500a4041d437a0aad8d69394b430.tar.gz
Intermediate changes
Diffstat (limited to 'library/cpp')
-rw-r--r--library/cpp/actors/core/actor_coroutine_ut.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/library/cpp/actors/core/actor_coroutine_ut.cpp b/library/cpp/actors/core/actor_coroutine_ut.cpp
index 951512b8772..f1fc4625b7c 100644
--- a/library/cpp/actors/core/actor_coroutine_ut.cpp
+++ b/library/cpp/actors/core/actor_coroutine_ut.cpp
@@ -67,6 +67,8 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
TAtomic& ItemsProcessed;
bool Finish;
+ struct TPoisonPillException {};
+
public:
TCoroActor(TManualEvent& doneEvent, TAtomic& itemsProcessed)
: TActorCoroImpl(1 << 20)
@@ -97,6 +99,8 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> event) override {
if (event->GetTypeRewrite() == Enough) {
Finish = true;
+ } else if (event->GetTypeRewrite() == TEvents::TSystem::Poison) {
+ throw TPoisonPillException();
}
}
};