update logger

Author: KirillKurdyukov

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs

@@ -204,17 +204,19 @@ await stream.Write(new MessageFromClient
         }
     }
 
-    public ValueTask DisposeAsync()
+    public async ValueTask DisposeAsync()
     {
         if (_disposeCts.IsCancellationRequested)
         {
-            return ValueTask.CompletedTask;
+            return;
         }
-        
+
         _receivedMessagesChannel.Writer.TryComplete();
         _disposeCts.Cancel();
 
-        return _currentReaderSession?.DisposeAsync() ?? ValueTask.CompletedTask;
+        await (_currentReaderSession?.DisposeAsync() ?? ValueTask.CompletedTask);
+
+        _logger.LogInformation("Reader[{WriterConfig}] is disposed", _config);
     }
 }
 
@@ -562,7 +564,7 @@ protected override MessageFromClient GetSendUpdateTokenRequest(string token)
 
     public override async ValueTask DisposeAsync()
     {
-        Logger.LogInformation("ReaderSession[{SessionId}]: start dispose process", SessionId);
+        Logger.LogDebug("ReaderSession[{SessionId}]: start dispose process", SessionId);
 
         _channelFromClientMessageSending.Writer.Complete();
 

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

@@ -338,8 +338,6 @@ public async ValueTask DisposeAsync()
             return;
         }
 
-        _logger.LogInformation("Starting Writer[{WriterConfig}] disposal process", _config);
-
         await _sendInFlightMessagesSemaphoreSlim.WaitAsync();
         try
         {
@@ -596,7 +594,7 @@ protected override MessageFromClient GetSendUpdateTokenRequest(string token)
 
     public override async ValueTask DisposeAsync()
     {
-        Logger.LogInformation("WriterSession[{SessionId}]: start dispose process", SessionId);
+        Logger.LogDebug("WriterSession[{SessionId}]: start dispose process", SessionId);
 
         await Stream.RequestStreamComplete();