diff options
author | abcdef <akotov@ydb.tech> | 2022-08-22 15:07:19 +0300 |
---|---|---|
committer | abcdef <akotov@ydb.tech> | 2022-08-22 15:07:19 +0300 |
commit | 11f534cfab6e582005dd74706656fb189f351507 (patch) | |
tree | 9aa5e0790f5138c1e6c6fe20b2fa02631591ede2 | |
parent | 585b7c1363f6ae222441fd24e9ff62872e5b75bb (diff) | |
download | ydb-11f534cfab6e582005dd74706656fb189f351507.tar.gz |
[-] экземпляр TDeferredActions удаляется первым
-rw-r--r-- | ydb/public/sdk/cpp/client/ydb_persqueue_core/ut/read_session_ut.cpp | 3 |
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); |