2.x: Remove unused declarations (#4527)

Author: vanniktech

src/main/java/io/reactivex/Scheduler.java

@@ -256,9 +256,7 @@ public long now(TimeUnit unit) {
          * of this task has to happen (accounting for clock drifts).
          */
         final class PeriodicTask implements Runnable {
-            final long firstStartInNanoseconds;
             final Runnable decoratedRun;
-            final long firstNowNanoseconds;
             final SequentialDisposable sd;
             final long periodInNanoseconds;
             long count;
@@ -267,9 +265,7 @@ final class PeriodicTask implements Runnable {
 
             PeriodicTask(long firstStartInNanoseconds, Runnable decoratedRun,
                     long firstNowNanoseconds, SequentialDisposable sd, long periodInNanoseconds) {
-                this.firstStartInNanoseconds = firstStartInNanoseconds;
                 this.decoratedRun = decoratedRun;
-                this.firstNowNanoseconds = firstNowNanoseconds;
                 this.sd = sd;
                 this.periodInNanoseconds = periodInNanoseconds;
                 lastNowNanoseconds = firstNowNanoseconds;

src/main/java/io/reactivex/internal/operators/completable/CompletableConcatIterable.java

@@ -54,8 +54,6 @@ static final class ConcatInnerObserver extends AtomicInteger implements Completa
         final CompletableObserver actual;
         final Iterator<? extends CompletableSource> sources;
 
-        int index;
-
         final SequentialDisposable sd;
 
         public ConcatInnerObserver(CompletableObserver actual, Iterator<? extends CompletableSource> sources) {

src/main/java/io/reactivex/internal/operators/flowable/FlowableDebounce.java

@@ -46,8 +46,6 @@ static final class DebounceSubscriber<T, U> extends AtomicLong
         final Subscriber<? super T> actual;
         final Function<? super T, ? extends Publisher<U>> debounceSelector;
 
-        volatile boolean gate;
-
         Subscription s;
 
         final AtomicReference<Disposable> debouncer = new AtomicReference<Disposable>();

src/main/java/io/reactivex/internal/operators/flowable/FlowableFromArray.java

@@ -27,9 +27,6 @@ public final class FlowableFromArray<T> extends Flowable<T> {
     public FlowableFromArray(T[] array) {
         this.array = array;
     }
-    public T[] array() {
-        return array; // NOPMD
-    }
     @Override
     public void subscribeActual(Subscriber<? super T> s) {
         if (s instanceof ConditionalSubscriber) {

src/main/java/io/reactivex/internal/operators/flowable/FlowablePublishMulticast.java

@@ -144,8 +144,6 @@ static final class MulticastProcessor<T> extends Flowable<T> implements Subscrib
 
         final int prefetch;
 
-        final int limit;
-
         final boolean delayError;
 
         final AtomicReference<Subscription> s;
@@ -161,7 +159,6 @@ static final class MulticastProcessor<T> extends Flowable<T> implements Subscrib
         public MulticastProcessor(int prefetch, boolean delayError) {
             this.prefetch = prefetch;
             this.delayError = delayError;
-            this.limit = prefetch - (prefetch >> 2);
             this.wip = new AtomicInteger();
             this.s = new AtomicReference<Subscription>();
             this.subscribers = new AtomicReference<MulticastSubscription<T>[]>(EMPTY);

src/main/java/io/reactivex/internal/operators/maybe/MaybeFlatMapCompletable.java

@@ -54,8 +54,6 @@ static final class FlatMapCompletableObserver<T>
 
         final Function<? super T, ? extends CompletableSource> mapper;
 
-        Disposable d;
-
         public FlatMapCompletableObserver(CompletableObserver actual,
                 Function<? super T, ? extends CompletableSource> mapper) {
             this.actual = actual;

src/main/java/io/reactivex/internal/operators/observable/ObservableCombineLatest.java

@@ -76,9 +76,7 @@ static final class LatestCoordinator<T, R> extends AtomicInteger implements Disp
         private static final long serialVersionUID = 8567835998786448817L;
         final Observer<? super R> actual;
         final Function<? super Object[], ? extends R> combiner;
-        final int count;
         final CombinerSubscriber<T, R>[] subscribers;
-        final int bufferSize;
         final T[] latest;
         final SpscLinkedArrayQueue<Object> queue;
         final boolean delayError;
@@ -98,8 +96,6 @@ public LatestCoordinator(Observer<? super R> actual,
                 int count, int bufferSize, boolean delayError) {
             this.actual = actual;
             this.combiner = combiner;
-            this.count = count;
-            this.bufferSize = bufferSize;
             this.delayError = delayError;
             this.latest = (T[])new Object[count];
             this.subscribers = new CombinerSubscriber[count];

src/main/java/io/reactivex/internal/operators/observable/ObservableDebounce.java

@@ -41,8 +41,6 @@ static final class DebounceSubscriber<T, U>
         final Observer<? super T> actual;
         final Function<? super T, ? extends ObservableSource<U>> debounceSelector;
 
-        volatile boolean gate;
-
         Disposable s;
 
         final AtomicReference<Disposable> debouncer = new AtomicReference<Disposable>();

src/main/java/io/reactivex/internal/operators/observable/ObservableFromArray.java

@@ -22,9 +22,6 @@ public final class ObservableFromArray<T> extends Observable<T> {
     public ObservableFromArray(T[] array) {
         this.array = array;
     }
-    public T[] array() {
-        return array; // NOPMD
-    }
     @Override
     public void subscribeActual(Observer<? super T> s) {
         FromArrayDisposable<T> d = new FromArrayDisposable<T>(s, array);

src/main/java/io/reactivex/internal/operators/observable/ObservableMapNotification.java

@@ -52,10 +52,6 @@ static final class MapNotificationSubscriber<T, R>
 
         Disposable s;
 
-        Observable<? extends R> value;
-
-        volatile boolean done;
-
         public MapNotificationSubscriber(Observer<? super ObservableSource<? extends R>> actual,
                 Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper,
                 Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper,