We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7383ea commit bc83841Copy full SHA for bc83841
src/Ydb.Sdk/src/Services/Topic/Producer.cs
@@ -147,7 +147,7 @@ internal async Task RunProcessingWriteAck(ConcurrentQueue<MessageSending> inFlig
147
try
148
{
149
Logger.LogInformation("ProducerSession[{SessionId}] is running processing writeAck", SessionId);
150
-
+
151
await foreach (var messageFromServer in _stream)
152
153
var status = Status.FromProto(messageFromServer.Status, messageFromServer.Issues);
0 commit comments