fix reordering of messages (#5337)

1 files changed, 5 insertions, 3 deletions

diff --git a/ydb/public/sdk/cpp/client/ydb_topic/impl/write_session_impl.cpp b/ydb/public/sdk/cpp/client/ydb_topic/impl/write_session_impl.cpp
index 27b8482186a..50558fbfe55 100644
--- a/ydb/public/sdk/cpp/client/ydb_topic/impl/write_session_impl.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_topic/impl/write_session_impl.cpp
@@ -827,6 +827,11 @@ void TWriteSessionImpl::OnReadDone(NYdbGrpc::TGrpcStatus&& grpcStatus, size_t co
             }
         }
     }
+
+    for (auto& event : processResult.Events) {
+        EventsQueue->PushEvent(std::move(event));
+    }
+
     if (doRead)
         ReadFromProcessor();
 
@@ -840,9 +845,6 @@ void TWriteSessionImpl::OnReadDone(NYdbGrpc::TGrpcStatus&& grpcStatus, size_t co
             CloseImpl(std::move(errorStatus));
         }
     }
-    for (auto& event : processResult.Events) {
-        EventsQueue->PushEvent(std::move(event));
-    }
     if (needSetValue) {
         InitSeqNoPromise.SetValue(*processResult.InitSeqNo);
         processResult.HandleResult.DoSetSeqNo = false; // Redundant. Just in case.