Make hasDownstreamCancelled protected instead of package-protected

smallrye · Sep 23, 2021 · a0d10e4 · a0d10e4
1 parent 30e9f79
commit a0d10e4
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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");