diff --git a/geode-wan/src/test/java/org/apache/geode/cache/wan/internal/WanCopyRegionFunctionServiceTest.java b/geode-wan/src/test/java/org/apache/geode/cache/wan/internal/WanCopyRegionFunctionServiceTest.java index 03596ba8b016..a298cead0805 100644 --- a/geode-wan/src/test/java/org/apache/geode/cache/wan/internal/WanCopyRegionFunctionServiceTest.java +++ b/geode-wan/src/test/java/org/apache/geode/cache/wan/internal/WanCopyRegionFunctionServiceTest.java @@ -164,6 +164,7 @@ public void severalExecuteWithDifferentRegionOrSenderAreAllowed() throws Interru }; final String regionName = String.valueOf(i); + final int expectedExecutions = i + 1; CompletableFuture .supplyAsync(() -> { try { @@ -177,7 +178,8 @@ public void severalExecuteWithDifferentRegionOrSenderAreAllowed() throws Interru // This ensures we don't have a race where multiple tasks try to start simultaneously // and only some get registered before we check the count await().untilAsserted( - () -> assertThat(service.getNumberOfCurrentExecutions()).isGreaterThanOrEqualTo(i + 1)); + () -> assertThat(service.getNumberOfCurrentExecutions()) + .isGreaterThanOrEqualTo(expectedExecutions)); } // Verify all executions are registered