Merge pull request #177 from smallrye/cs-publisher-cancellation-fix

Add a C&S step for CompletionStagePublisher cancellation
smallrye · Mar 14, 2024 · 3608cb9 · 3608cb9
2 parents 2053e75 + b5d31a8
commit 3608cb9
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/mutiny-zero/src/main/java/mutiny/zero/internal/CompletionStagePublisher.java b/mutiny-zero/src/main/java/mutiny/zero/internal/CompletionStagePublisher.java
@@ -86,8 +86,9 @@ public void request(long n) {
 
         @Override
         public void cancel() {
-            cancelled.set(true);
-            completableFuture.toCompletableFuture().cancel(false);
+            if (cancelled.compareAndSet(false, true)) {
+                completableFuture.toCompletableFuture().cancel(false);
+            }
         }
     }
 }