Skip to content

Commit 25eb094

Browse files
fix tests
1 parent 3631abc commit 25eb094

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/ReaderUnitTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -375,9 +375,9 @@ public async Task Initialize_WhenInitResponseStatusIsNotRetryable_ShouldThrowRea
375375
SubscribeSettings = { new SubscribeSettings("/topic") }
376376
}.Build();
377377

378-
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
378+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found",
379379
(await Assert.ThrowsAsync<ReaderException>(async () => await reader.ReadAsync())).Message);
380-
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
380+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found",
381381
(await Assert.ThrowsAsync<ReaderException>(async () => await reader.ReadBatchAsync())).Message);
382382

383383
_mockStream.Verify(stream => stream.Write(It.Is<FromClient>(msg =>

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/WriterUnitTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -295,9 +295,9 @@ public async Task
295295
await using var writer = new WriterBuilder<long>(_mockIDriver.Object, "/topic-6")
296296
{ ProducerId = "producerId" }.Build();
297297

298-
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
298+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found",
299299
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync(123L))).Message);
300-
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found\n",
300+
Assert.Equal("Initialization failed! Status: SchemeError, Issues:\n[0] Fatal: Topic not found",
301301
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync(1L))).Message);
302302

303303
// check not attempt repeated!!!

0 commit comments

Comments
 (0)