Merge pull request #1493 from smallrye/refactor/concatmap-no-cas-on-u…

…nbounded refactor: avoid a compare&swap on unbounded requests
smallrye · Jan 22, 2024 · e2bb9d9 · e2bb9d9
2 parents b8da91f + 4811b4b
commit e2bb9d9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiConcatMapOp.java
@@ -117,7 +117,9 @@ public void onItem(I item) {
 
         private void innerOnItem(O item) {
             if (state != State.DONE) {
-                DEMAND_UPDATER.decrementAndGet(this);
+                if (demand < Long.MAX_VALUE) {
+                    DEMAND_UPDATER.decrementAndGet(this);
+                }
                 downstream.onItem(item);
             }
         }