Skip to content

Commit 8fe04eb

Browse files
committed
Moved commit "fix reordering of messages" from ydb repo
1 parent 1a775f7 commit 8fe04eb

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

src/client/topic/impl/write_session_impl.cpp

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -846,6 +846,11 @@ void TWriteSessionImpl::OnReadDone(NYdbGrpc::TGrpcStatus&& grpcStatus, size_t co
846846
}
847847
}
848848
}
849+
850+
for (auto& event : processResult.Events) {
851+
EventsQueue->PushEvent(std::move(event));
852+
}
853+
849854
if (doRead)
850855
ReadFromProcessor();
851856

@@ -860,9 +865,6 @@ void TWriteSessionImpl::OnReadDone(NYdbGrpc::TGrpcStatus&& grpcStatus, size_t co
860865
CloseImpl(std::move(errorStatus));
861866
}
862867
}
863-
for (auto& event : processResult.Events) {
864-
EventsQueue->PushEvent(std::move(event));
865-
}
866868
if (needSetValue) {
867869
InitSeqNoPromise.SetValue(*processResult.InitSeqNo);
868870
processResult.HandleResult.DoSetSeqNo = false; // Redundant. Just in case.

0 commit comments

Comments
 (0)