fix setting SeqNo

KirillKurdyukov · KirillKurdyukov · commit 98f097c6fc5c · 2024-11-26T17:19:06.000+03:00
diff --git a/src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs b/src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs
@@ -343,7 +343,11 @@ public async Task Write(ConcurrentQueue<MessageSending> toSendBuffer)
             {
                 var messageData = sendData.MessageData;
 
-                messageData.SeqNo = messageData.SeqNo > 0 ? messageData.SeqNo : ++currentSeqNum;
+                if (messageData.SeqNo == default)
+                {
+                    messageData.SeqNo = ++currentSeqNum;
+                }
+
                 writeMessage.Messages.Add(messageData);
                 _inFlightMessages.Enqueue(sendData);
             }

Original file line number	Diff line number	Diff line change
`@@ -343,7 +343,11 @@ public async Task Write(ConcurrentQueue<MessageSending> toSendBuffer)`
`343`	`343`	`{`
`344`	`344`	`var messageData = sendData.MessageData;`
`345`	`345`
`346`		`- messageData.SeqNo = messageData.SeqNo > 0 ? messageData.SeqNo : ++currentSeqNum;`
	`346`	`+ if (messageData.SeqNo == default)`
	`347`	`+ {`
	`348`	`+ messageData.SeqNo = ++currentSeqNum;`
	`349`	`+ }`
	`350`	`+`
`347`	`351`	`writeMessage.Messages.Add(messageData);`
`348`	`352`	`_inFlightMessages.Enqueue(sendData);`
`349`	`353`	`}`