Moved commit "ydb_topic: Call non-dataEvent callbacks immediately" from ydb repo

Author: qyryq

src/client/topic/impl/read_session_impl.ipp

@@ -1948,7 +1948,7 @@ void TSingleClusterReadSessionImpl<UseMigrationProtocol>::TrySubscribeOnTransact
 
         auto callback = [cbContext = this->SelfContext, txId, txInfo, consumer = Settings.ConsumerName_, client]() {
             std::vector<TTopicOffsets> offsets;
-            
+
             with_lock (txInfo->Lock) {
                 Y_ABORT_UNLESS(!txInfo->CommitCalled);
 
@@ -2083,6 +2083,13 @@ bool TReadSessionEventsQueue<UseMigrationProtocol>::PushEvent(TIntrusivePtr<TPar
         stream->DeleteNotReadyTail(deferred);
     }
 
+    if (!HasDataEventCallback() && !std::holds_alternative<TADataReceivedEvent<UseMigrationProtocol>>(event)) {
+        // Call non-dataEvent callbacks immediately.
+        if (TryApplyCallbackToEventImpl(event, deferred, CbContext)) {
+            return true;
+        }
+    }
+
     stream->InsertEvent(std::move(event));
     Y_ASSERT(stream->HasEvents());