File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
src/Ydb.Sdk/src/Services/Topic Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -24,7 +24,8 @@ protected TopicSession(
2424 _initialize = initialize ;
2525 }
2626
27- protected async void ReconnectSession ( ) {
27+ protected async void ReconnectSession ( )
28+ {
2829 if ( Interlocked . CompareExchange ( ref _isActive , 0 , 1 ) == 0 )
2930 {
3031 Logger . LogDebug ( "Skipping reconnect. A reconnect session has already been initiated" ) ;
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ internal WriterConfig(
99 string ? producerId ,
1010 Codec codec ,
1111 int bufferMaxSize ,
12- long ? partitionId ,
12+ long ? partitionId ,
1313 int bufferOverflowRetryTimeoutMs )
1414 {
1515 TopicPath = topicPath ;
@@ -29,7 +29,7 @@ internal WriterConfig(
2929 public int BufferMaxSize { get ; }
3030
3131 public long ? PartitionId { get ; }
32-
32+
3333 public int BufferOverflowRetryTimeoutMs { get ; }
3434
3535 public override string ToString ( )
You can’t perform that action at this time.
0 commit comments