2.x: Remove some unused fields (#4754)

Author: vanniktech

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

@@ -45,8 +45,6 @@ public final class BlockingFlowableIterator<T>
     volatile boolean done;
     Throwable error;
 
-    volatile boolean cancelled;
-
     public BlockingFlowableIterator(int batchSize) {
         this.queue = new SpscLinkedArrayQueue<T>(batchSize);
         this.batchSize = batchSize;
@@ -58,9 +56,6 @@ public BlockingFlowableIterator(int batchSize) {
     @Override
     public boolean hasNext() {
         for (;;) {
-            if (cancelled) {
-                return false;
-            }
             boolean d = done;
             boolean empty = queue.isEmpty();
             if (d) {
@@ -75,7 +70,7 @@ public boolean hasNext() {
             if (empty) {
                 lock.lock();
                 try {
-                    while (!cancelled && !done && queue.isEmpty()) {
+                    while (!done && queue.isEmpty()) {
                         condition.await();
                     }
                 } catch (InterruptedException ex) {

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

@@ -60,10 +60,6 @@ static final class DistinctSubscriber<T, K> extends BasicFuseableSubscriber<T, T
 
         final Function<? super T, K> keySelector;
 
-        Disposable d;
-
-        SimpleQueue<T> queue;
-
         DistinctSubscriber(Subscriber<? super T> actual, Function<? super T, K> keySelector, Collection<? super K> collection) {
             super(actual);
             this.keySelector = keySelector;

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

@@ -59,10 +59,6 @@ static final class DistinctObserver<T, K> extends BasicFuseableObserver<T, T> {
 
         final Function<? super T, K> keySelector;
 
-        Disposable d;
-
-        SimpleQueue<T> queue;
-
         DistinctObserver(Observer<? super T> actual, Function<? super T, K> keySelector, Collection<? super K> collection) {
             super(actual);
             this.keySelector = keySelector;

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

@@ -33,8 +33,6 @@ public void subscribeActual(Observer<? super T> s) {
     static final class FilterObserver<T> extends BasicFuseableObserver<T, T> {
         final Predicate<? super T> filter;
 
-        Disposable s;
-
         FilterObserver(Observer<? super T> actual, Predicate<? super T> filter) {
             super(actual);
             this.filter = filter;