Skip to content

Commit 6159dae

Browse files
committed
simplify checking for heartbeat pairs
1 parent 0f930ae commit 6159dae

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

tests/MongoDB.Driver.Tests/Specifications/sessions/SessionsProseTests.cs

+4-8
Original file line numberDiff line numberDiff line change
@@ -337,15 +337,11 @@ public void Ensure_cluster_times_are_not_gossiped_on_SDAM_commands()
337337
eventCapturer.Clear();
338338

339339
eventCapturer.WaitForOrThrowIfTimeout(
340-
events =>
340+
capturedEvents =>
341341
{
342-
var capturedEvents = events.ToArray();
343-
return capturedEvents.Count(e => e is ServerHeartbeatSucceededEvent) > 1 &&
344-
capturedEvents
345-
.Where((e, i) =>
346-
e is ServerHeartbeatStartedEvent &&
347-
capturedEvents[i + 1] is ServerHeartbeatSucceededEvent)
348-
.Any();
342+
return capturedEvents
343+
.SkipWhile(e => e is not ServerHeartbeatStartedEvent)
344+
.Any(e => e is ServerHeartbeatSucceededEvent);
349345
}, TimeSpan.FromSeconds(1), "Didn't get any server heartbeat pairs");
350346

351347
c1.GetDatabase("admin").RunCommand<BsonDocument>(pingCommand);

0 commit comments

Comments
 (0)