2.x: Remove unused declarations

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,

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

@@ -34,8 +34,6 @@ static final class MaterializeSubscriber<T> implements Observer<T>, Disposable {
 
         Disposable s;
 
-        volatile boolean done;
-
         public MaterializeSubscriber(Observer<? super Notification<T>> actual) {
             this.actual = actual;
         }

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

@@ -62,7 +62,6 @@ static final class ObserveOnSubscriber<T> extends Padding0 implements Observer<T
         final Observer<? super T> actual;
         final Scheduler.Worker worker;
         final boolean delayError;
-        final int bufferSize;
         final SpscLinkedArrayQueue<T> queue;
 
         Disposable s;
@@ -76,7 +75,6 @@ public ObserveOnSubscriber(Observer<? super T> actual, Scheduler.Worker worker,
             this.actual = actual;
             this.worker = worker;
             this.delayError = delayError;
-            this.bufferSize = bufferSize;
             this.queue = new SpscLinkedArrayQueue<T>(bufferSize);
         }
 

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

@@ -37,8 +37,6 @@ static final class OnErrorReturnSubscriber<T> implements Observer<T>, Disposable
 
         Disposable s;
 
-        volatile boolean done;
-
         public OnErrorReturnSubscriber(Observer<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier) {
             this.actual = actual;
             this.valueSupplier = valueSupplier;
@@ -70,7 +68,6 @@ public void onNext(T t) {
 
         @Override
         public void onError(Throwable t) {
-            done = true;
             T v;
             try {
                 v = valueSupplier.apply(t);

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

@@ -223,8 +223,6 @@ static final class PublishSubscriber<T> implements Observer<T>, Disposable {
         final SpscLinkedArrayQueue<Object> queue;
         /** Holds onto the current connected PublishSubscriber. */
         final AtomicReference<PublishSubscriber<T>> current;
-        /** The prefetch buffer size. */
-        final int bufferSize;
         /** Contains either an onCompleted or an onError token from upstream. */
         volatile Object terminalEvent;
 
@@ -254,7 +252,6 @@ public PublishSubscriber(AtomicReference<PublishSubscriber<T>> current, int buff
             this.producers = new AtomicReference<InnerProducer[]>(EMPTY);
             this.current = current;
             this.shouldConnect = new AtomicBoolean();
-            this.bufferSize = bufferSize;
         }
 
         @Override

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

@@ -338,12 +338,6 @@ static final class ReplaySubscriber<T> implements Observer<T>, Disposable {
          */
         final AtomicBoolean shouldConnect;
 
-        /** Guarded by this. */
-        boolean emitting;
-        /** Guarded by this. */
-        boolean missed;
-
-
         /** The upstream producer. */
         volatile Disposable subscription;
 

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

@@ -223,8 +223,6 @@ static final class EqualSubscriber<T> implements Observer<T> {
         volatile boolean done;
         Throwable error;
 
-        Disposable s;
-
         public EqualSubscriber(EqualCoordinator<T> parent, int index, int bufferSize) {
             this.parent = parent;
             this.index = index;
@@ -233,9 +231,7 @@ public EqualSubscriber(EqualCoordinator<T> parent, int index, int bufferSize) {
 
         @Override
         public void onSubscribe(Disposable s) {
-            if (parent.setSubscription(s, index)) {
-                this.s = s;
-            }
+            parent.setSubscription(s, index);
         }
 
         @Override

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

@@ -312,15 +312,13 @@ static final class SwitchMapInnerSubscriber<T, R> extends AtomicReference<Dispos
         private static final long serialVersionUID = 3837284832786408377L;
         final SwitchMapSubscriber<T, R> parent;
         final long index;
-        final int bufferSize;
         final SpscArrayQueue<R> queue;
 
         volatile boolean done;
 
         public SwitchMapInnerSubscriber(SwitchMapSubscriber<T, R> parent, long index, int bufferSize) {
             this.parent = parent;
             this.index = index;
-            this.bufferSize = bufferSize;
             this.queue = new SpscArrayQueue<R>(bufferSize);
         }
 

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

@@ -40,7 +40,6 @@ static final class TakeLastSubscriber<T> extends ArrayDeque<T> implements Observ
 
         Disposable s;
 
-        volatile boolean done;
         volatile boolean cancelled;
 
         public TakeLastSubscriber(Observer<? super T> actual, int count) {
@@ -71,7 +70,6 @@ public void onError(Throwable t) {
 
         @Override
         public void onComplete() {
-            done = true;
             if (cancelled) {
                 return;
             }

src/main/java/io/reactivex/internal/operators/single/SingleFlatMapCompletable.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;