fix linter

KirillKurdyukov · KirillKurdyukov · commit ce61a542348b · 2024-11-17T21:23:47.000+03:00
diff --git a/src/Ydb.Sdk/src/Services/Topic/TopicSession.cs b/src/Ydb.Sdk/src/Services/Topic/TopicSession.cs
@@ -31,7 +31,7 @@ protected async void ReconnectSession()
         }
 
         Logger.LogInformation("WriterSession[{SessionId}] has been deactivated, starting to reconnect", SessionId);
-        
+
         await _initialize();
     }
 
diff --git a/src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs b/src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs
@@ -71,7 +71,7 @@ public async Task<WriteResult> WriteAsync(Message<TValue> message)
             var curLimitBufferSize = Volatile.Read(ref _limitBufferMaxSize);
 
             if ( // sending one biggest message anyway
-                curLimitBufferSize == _config.BufferMaxSize && data.Length > curLimitBufferSize
+                (curLimitBufferSize == _config.BufferMaxSize && data.Length > curLimitBufferSize)
                 || curLimitBufferSize >= data.Length)
             {
                 if (Interlocked.CompareExchange(ref _limitBufferMaxSize,

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ protected async void ReconnectSession()`
`31`	`31`	`}`
`32`	`32`
`33`	`33`	`Logger.LogInformation("WriterSession[{SessionId}] has been deactivated, starting to reconnect", SessionId);`
`34`		`-`
	`34`	`+`
`35`	`35`	`await _initialize();`
`36`	`36`	`}`
`37`	`37`
Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ public async Task<WriteResult> WriteAsync(Message<TValue> message)`
`71`	`71`	`var curLimitBufferSize = Volatile.Read(ref _limitBufferMaxSize);`
`72`	`72`
`73`	`73`	`if ( // sending one biggest message anyway`
`74`		`- curLimitBufferSize == _config.BufferMaxSize && data.Length > curLimitBufferSize`
	`74`	`+ (curLimitBufferSize == _config.BufferMaxSize && data.Length > curLimitBufferSize)`
`75`	`75`	`\|\| curLimitBufferSize >= data.Length)`
`76`	`76`	`{`
`77`	`77`	`if (Interlocked.CompareExchange(ref _limitBufferMaxSize,`