diff --git a/build.gradle b/build.gradle index e10bf526c7..17ccd116ac 100644 --- a/build.gradle +++ b/build.gradle @@ -273,6 +273,8 @@ 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'] } javadoc { diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxDelaySequence.java b/reactor-core/src/main/java/reactor/core/publisher/FluxDelaySequence.java index 80627234fe..aa1407fb8a 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxDelaySequence.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxDelaySequence.java @@ -28,12 +28,12 @@ * @author Simon Baslé */ //adapted from RxJava2 FlowableDelay: https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/internal/operators/flowable/FlowableDelay.java -public final class FluxDelaySequence extends FluxOperator { +final class FluxDelaySequence extends FluxOperator { final Duration delay; final Scheduler scheduler; - public FluxDelaySequence(Flux source, Duration delay, Scheduler scheduler) { + FluxDelaySequence(Flux source, Duration delay, Scheduler scheduler) { super(source); this.delay = delay; this.scheduler = scheduler; diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxIndex.java b/reactor-core/src/main/java/reactor/core/publisher/FluxIndex.java index e0c8920c16..2289eca41e 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxIndex.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxIndex.java @@ -34,7 +34,7 @@ * * @author Simon Baslé */ -public class FluxIndex extends FluxOperator { +final class FluxIndex extends FluxOperator { private final BiFunction indexMapper; diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java b/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java index e823e020fa..73e49c2488 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java +++ b/reactor-core/src/main/java/reactor/core/publisher/FluxIndexFuseable.java @@ -51,7 +51,7 @@ * * @author Simon Baslé */ -public class FluxIndexFuseable extends FluxOperator +final class FluxIndexFuseable extends FluxOperator implements Fuseable { private final BiFunction indexMapper;