Skip to content

Commit 3671a8d

Browse files
fix test
1 parent f7ca606 commit 3671a8d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -336,7 +336,7 @@ public async ValueTask DisposeAsync()
336336
await _sendInFlightMessagesSemaphoreSlim.WaitAsync();
337337
try
338338
{
339-
_disposeCts.Dispose();
339+
_disposeCts.Cancel();
340340
}
341341
finally
342342
{

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -719,7 +719,7 @@ public async Task WriteAsync_WhenWriterIsDisposed_ThrowWriterException()
719719
{ ProducerId = "producerId" }.Build();
720720
await writer.DisposeAsync();
721721

722-
Assert.Equal("Writer[TopicPath: /topic-15, ProducerId: producerId, Codec: Raw] is disposed",
722+
Assert.Equal("Writer[TopicPath: /topic-14, ProducerId: producerId, Codec: Raw] is disposed",
723723
(await Assert.ThrowsAsync<WriterException>(() => writer.WriteAsync("abacaba"))).Message);
724724
}
725725

0 commit comments

Comments
 (0)