Skip to content

Commit 65d6b57

Browse files
fix linter
1 parent b9cfcc6 commit 65d6b57

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ internal static long CalculateApproximatelyBytesSize(long bytesSize, int countPa
66
{
77
return bytesSize / countParts + (currentIndex == countParts - 1 ? bytesSize % countParts : 0);
88
}
9-
9+
1010
internal static void SetPartitionClosedException(CommitSending commitSending, long partitionSessionId)
1111
{
1212
commitSending.TcsCommit.TrySetException(

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ public async Task StressTest_WhenReadingThenCommiting_ReturnMessages()
4141
Assert.Equal($"{i}: Hello World!", message.Data);
4242
await message.CommitAsync();
4343
}
44+
4445
reader.Dispose();
4546

4647
var readerNext = new ReaderBuilder<string>(_driver)
@@ -59,7 +60,7 @@ public async Task StressTest_WhenReadingThenCommiting_ReturnMessages()
5960
}
6061

6162
readerNext.Dispose();
62-
63+
6364
await topicClient.DropTopic(new DropTopicSettings { Path = _topicName });
6465
}
6566
}

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
using Google.Protobuf;
22
using Grpc.Core;
33
using Moq;
4-
using Xunit;
54
using Ydb.Sdk.Services.Topic.Reader;
65
using Ydb.Topic;
76

@@ -113,7 +112,7 @@ public async Task Initialize_WhenFailWriteMessage_ShouldRetryInitializeAndReadTh
113112
SubscribeSettings = { new SubscribeSettings("/topic") }
114113
}.Build();
115114

116-
var message = await reader.ReadAsync();
115+
await reader.ReadAsync();
117116
// await message.CommitAsync();
118117
// Assert.Equal(100, message.Data);
119118
}

0 commit comments

Comments
 (0)