Skip to content

Commit c44c6af

Browse files
fix: run processing ack may not be able to start on time in test (#237)
1 parent 5a4ac3f commit c44c6af

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,9 +130,9 @@ public async Task Initialize_WhenFailWriteMessage_ShouldRetryInitializeAndReturn
130130
Assert.Equal(PersistenceStatus.Written, (await writer.WriteAsync("abacaba")).Status);
131131

132132
// check attempt repeated!!!
133-
_mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()),
133+
_mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Exactly(3));
134+
_mockStream.Verify(stream => stream.MoveNextAsync(),
134135
Times.AtLeast(2)); // run processing ack may not be able to start on time
135-
_mockStream.Verify(stream => stream.MoveNextAsync(), Times.Exactly(3));
136136
_mockStream.Verify(stream => stream.Current, Times.Exactly(2));
137137
}
138138

0 commit comments

Comments
 (0)