diff --git a/mutiny-zero/src/main/java/mutiny/zero/internal/CompletionStagePublisher.java b/mutiny-zero/src/main/java/mutiny/zero/internal/CompletionStagePublisher.java
index f5f71ea..01f3c65 100644
--- 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);
         }
     }
 }