diff --git a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiOperatorProcessor.java b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiOperatorProcessor.java
index 555c3df01..290be5479 100644
--- a/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiOperatorProcessor.java
+++ b/implementation/src/main/java/io/smallrye/mutiny/operators/multi/MultiOperatorProcessor.java
@@ -16,7 +16,7 @@ public abstract class MultiOperatorProcessor<I, O> implements MultiSubscriber<I>
     // Cannot be final, the TCK checks it gets released.
     protected volatile MultiSubscriber<? super O> downstream;
     protected volatile Subscription upstream = null;
-    AtomicBoolean hasDownstreamCancelled = new AtomicBoolean();
+    protected AtomicBoolean hasDownstreamCancelled = new AtomicBoolean();
 
     private static final AtomicReferenceFieldUpdater<MultiOperatorProcessor, Subscription> UPSTREAM_UPDATER = AtomicReferenceFieldUpdater
             .newUpdater(MultiOperatorProcessor.class, Subscription.class, "upstream");