aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorabcdef <akotov@ydb.tech>2022-08-22 15:07:19 +0300
committerabcdef <akotov@ydb.tech>2022-08-22 15:07:19 +0300
commit11f534cfab6e582005dd74706656fb189f351507 (patch)
tree9aa5e0790f5138c1e6c6fe20b2fa02631591ede2
parent585b7c1363f6ae222441fd24e9ff62872e5b75bb (diff)
downloadydb-11f534cfab6e582005dd74706656fb189f351507.tar.gz
[-] экземпляр TDeferredActions удаляется первым
-rw-r--r--ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp
index 7df28277ee..0437f64720 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp
@@ -1884,7 +1884,6 @@ Y_UNIT_TEST_SUITE(ReadSessionImplTest) {
UNIT_ASSERT_VALUES_EQUAL(std::get<TExpectedEvent>(event.GetEvent()).GetMessagesCount(), count); \
}
- TDeferredActions<true> actions;
TAReadSessionSettings<true> settings;
std::shared_ptr<TSingleClusterReadSessionImpl<true>> session;
TReadSessionEventsQueue<true> sessionQueue{settings, session};
@@ -1921,6 +1920,8 @@ Y_UNIT_TEST_SUITE(ReadSessionImplTest) {
stream->InsertEvent(TServiceEvent{stream, 0, 0, 0, {}});
stream->InsertDataEvent(0, 0, data, ready);
+ TDeferredActions<true> actions;
+
stream->SignalReadyEvents(&sessionQueue,
actions);