Add a C&S step for CompletionStagePublisher cancellation

We're observing some RS TCK failures in slow CI conditions.
smallrye · Mar 14, 2024 · b5d31a8 · b5d31a8
1 parent 2053e75
commit b5d31a8
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);
+            }
         }
     }
 }