Skip to content

Commit 04d9f85

Browse files
fix flap tests
1 parent 011f076 commit 04d9f85

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,7 +1075,7 @@ public async Task
10751075
Assert.Equal("Hello", batch.Batch[0].Data);
10761076
Assert.Equal("World!", batch.Batch[1].Data);
10771077

1078-
_mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Exactly(11));
1078+
_mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Between(11, 12, Range.Inclusive));
10791079
_mockStream.Verify(stream => stream.MoveNextAsync(), Times.Between(8, 9, Range.Inclusive));
10801080
_mockStream.Verify(stream => stream.Current, Times.Exactly(7));
10811081

@@ -1094,7 +1094,7 @@ public async Task
10941094
msg.CommitOffsetRequest != null &&
10951095
msg.CommitOffsetRequest.CommitOffsets[0].PartitionSessionId == 1 &&
10961096
msg.CommitOffsetRequest.CommitOffsets[0].Offsets[0].Start == 0 &&
1097-
msg.CommitOffsetRequest.CommitOffsets[0].Offsets[0].End == 21)));
1097+
msg.CommitOffsetRequest.CommitOffsets[0].Offsets[0].End == 21)), Times.AtLeast(1));
10981098
}
10991099

11001100
/*

0 commit comments

Comments
 (0)