Fix shouldShortcircuitOnExceptionTest (#815)

pivovarit · Jan 21, 2024 · f71ed24 · f71ed24
1 parent 5d9450c
commit f71ed24
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/java/com/pivovarit/collectors/TestUtils.java b/src/test/java/com/pivovarit/collectors/TestUtils.java
@@ -36,8 +36,8 @@ public static <T> T returnWithDelay(T value, Duration duration) {
         return value;
     }
 
-    public static Integer incrementAndThrow(AtomicInteger counter) {
-        if (counter.incrementAndGet() == 10) {
+    public synchronized static Integer incrementAndThrow(AtomicInteger counter) {
+        if (counter.incrementAndGet() >= 10) {
             throw new IllegalArgumentException();
         }