Skip to content

Commit a6f0ccf

Browse files
fix linter
1 parent 31fd7e7 commit a6f0ccf

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

src/Ydb.Sdk/src/IDriver.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public interface IBidirectionalStream<in TRequest, out TResponse> : IDisposable
3737
public ValueTask<bool> MoveNextAsync();
3838

3939
public TResponse Current { get; }
40-
40+
4141
public string? AuthToken { get; }
4242
}
4343

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,16 +45,16 @@ protected async void ReconnectSession()
4545
protected async Task SendMessage(TFromClient fromClient)
4646
{
4747
var curAuthToken = Stream.AuthToken;
48-
48+
4949
if (!string.Equals(_lastToken, curAuthToken) && curAuthToken != null)
5050
{
5151
var updateTokenRequest = GetSendUpdateTokenRequest(curAuthToken);
5252

5353
_lastToken = curAuthToken;
54-
54+
5555
await Stream.Write(updateTokenRequest);
5656
}
57-
57+
5858
await Stream.Write(fromClient);
5959
}
6060

src/Ydb.Sdk/tests/Topic/WriterUnitTests.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
using Moq.Language;
44
using Xunit;
55
using Ydb.Issue;
6-
using Ydb.Sdk.Auth;
76
using Ydb.Sdk.Services.Topic;
87
using Ydb.Sdk.Services.Topic.Writer;
98
using Ydb.Topic;
@@ -831,10 +830,10 @@ public async Task WriteAsync_WhenTokenIsUpdatedOneTime_SuccessUpdateToken()
831830

832831
var writeTask2 = await writer.WriteAsync(100);
833832
Assert.Equal(PersistenceStatus.Written, writeTask2.Status);
834-
833+
835834
var writeTask3 = await writer.WriteAsync(100);
836835
Assert.Equal(PersistenceStatus.Written, writeTask3.Status);
837-
836+
838837
_mockStream.Verify(stream => stream.MoveNextAsync(), Times.Between(4, 5, Range.Inclusive));
839838
_mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Exactly(5));
840839
_mockStream.Verify(stream => stream.Write(It.Is<FromClient>(msg =>

0 commit comments

Comments
 (0)