Simplify cancellation

smallrye · Mar 14, 2024 · 2183aea · 2183aea
1 parent 3608cb9
commit 2183aea
Showing 1 changed file with 2 additions and 3 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,9 +86,8 @@ public void request(long n) {
 
         @Override
         public void cancel() {
-            if (cancelled.compareAndSet(false, true)) {
-                completableFuture.toCompletableFuture().cancel(false);
-            }
+            completableFuture.cancel(false);
+            cancelled.set(true);
         }
     }
 }