diff --git a/build.gradle b/build.gradle index 17ccd116ac..cb0308d819 100644 --- a/build.gradle +++ b/build.gradle @@ -274,7 +274,7 @@ project('reactor-core') { //TODO after a release, bump the gradle.properties baseline //TODO after a release, remove the reactor-core exclusions below if any //gh-1036 - classExcludes = ['reactor.core.publisher.FluxIndex', 'reactor.core.publisher.FluxIndexFuseable', 'reactor.core.publisher.FluxDelaySequence'] + classExcludes = ['reactor.core.publisher.FluxIndex', 'reactor.core.publisher.FluxIndexFuseable', 'reactor.core.publisher.FluxDelaySequence', 'reactor.util.concurrent.MpscLinkedQueue'] } javadoc { diff --git a/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java b/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java index c63ee2dc30..87d315a68e 100644 --- a/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java +++ b/reactor-core/src/main/java/reactor/util/concurrent/MpscLinkedQueue.java @@ -32,7 +32,7 @@ * A multi-producer single consumer unbounded queue. * @param the contained value type */ -public class MpscLinkedQueue extends AbstractQueue implements BiPredicate { +final class MpscLinkedQueue extends AbstractQueue implements BiPredicate { private volatile LinkedQueueNode producerNode; private final static AtomicReferenceFieldUpdater PRODUCER_NODE_UPDATER