diff options
| -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 7df28277ee7..0437f64720f 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); |