From a0d10e464a2e30c40875482ea8338e270d15039a Mon Sep 17 00:00:00 2001 From: Julien Ponge Date: Thu, 23 Sep 2021 18:24:32 +0200 Subject: [PATCH] Make hasDownstreamCancelled protected instead of package-protected --- .../smallrye/mutiny/operators/multi/MultiOperatorProcessor.java | 2 +- 1 file changed, 1 insertion(+), 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 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 implements MultiSubscriber // Cannot be final, the TCK checks it gets released. protected volatile MultiSubscriber downstream; protected volatile Subscription upstream = null; - AtomicBoolean hasDownstreamCancelled = new AtomicBoolean(); + protected AtomicBoolean hasDownstreamCancelled = new AtomicBoolean(); private static final AtomicReferenceFieldUpdater UPSTREAM_UPDATER = AtomicReferenceFieldUpdater .newUpdater(MultiOperatorProcessor.class, Subscription.class, "upstream");