bug: Unhandled exception. System.Net.Http.HttpIOException

Author: KirillKurdyukov

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

@@ -198,9 +198,9 @@ await stream.AuthToken(),
                 _deserializer
             );
         }
-        catch (Driver.TransportException e)
+        catch (Exception e)
         {
-            _logger.LogError(e, "Transport error on executing ReaderSession");
+            _logger.LogError(e, "Error on executing ReaderSession");
 
             _ = Task.Run(Initialize, _disposeCts.Token);
         }
@@ -338,9 +338,9 @@ private async Task RunProcessingStreamResponse()
 
             Logger.LogInformation("ReaderSession[{SessionId}]: ResponseStream is closed", SessionId);
         }
-        catch (Driver.TransportException e)
+        catch (Exception e)
         {
-            Logger.LogError(e, "ReaderSession[{SessionId}] have transport error on processing server messages",
+            Logger.LogError(e, "ReaderSession[{SessionId}] have error on processing server messages",
                 SessionId);
         }
         finally
@@ -360,7 +360,7 @@ private async Task RunProcessingStreamRequest()
                 await SendMessage(messageFromClient);
             }
         }
-        catch (Driver.TransportException e)
+        catch (Exception e)
         {
             Logger.LogError(e, "ReaderSession[{SessionId}] have transport error on Write", SessionId);
 

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

@@ -314,16 +314,16 @@ await stream.AuthToken(),
                 _sendInFlightMessagesSemaphoreSlim.Release();
             }
         }
-        catch (Driver.TransportException e)
-        {
-            _logger.LogError(e, "Transport error on creating WriterSession");
-
-            _ = Task.Run(Initialize);
-        }
         catch (OperationCanceledException)
         {
             _logger.LogInformation("Initialize writer is canceled because it has been disposed");
         }
+        catch (Exception e)
+        {
+            _logger.LogError(e, "Error on creating WriterSession");
+
+            _ = Task.Run(Initialize);
+        }
     }
 
     public async ValueTask DisposeAsync()
@@ -493,7 +493,7 @@ public async Task Write(ConcurrentQueue<MessageSending> toSendBuffer)
             Volatile.Write(ref _seqNum, currentSeqNum);
             await SendMessage(new MessageFromClient { WriteRequest = writeMessage });
         }
-        catch (Driver.TransportException e)
+        catch (Exception e)
         {
             Logger.LogError(e, "WriterSession[{SessionId}] have transport error on Write, last SeqNo={SeqNo}",
                 SessionId, Volatile.Read(ref _seqNum));
@@ -564,7 +564,7 @@ Completing task on exception...
 
             Logger.LogInformation("WriterSession[{SessionId}]: ResponseStream is closed", SessionId);
         }
-        catch (Driver.TransportException e)
+        catch (Exception e)
         {
             Logger.LogError(e, "WriterSession[{SessionId}] have error on processing writeAck", SessionId);
         }