refactor: avoid a compare&swap on unbounded requests

smallrye · Jan 22, 2024 · 4811b4b · 4811b4b
1 parent b8da91f
commit 4811b4b
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);
             }
         }