2.x: Remove some dead code (#4581)

Author: vanniktech

src/main/java/io/reactivex/internal/observers/InnerQueuedObserver.java

@@ -42,8 +42,6 @@ public final class InnerQueuedObserver<T>
 
     volatile boolean done;
 
-    long produced;
-
     int fusionMode;
 
     public InnerQueuedObserver(InnerQueuedObserverSupport<T> parent, int prefetch) {

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

@@ -188,14 +188,6 @@ public static <T, U> Function<T, Publisher<U>> flatMapIntoIterable(final Functio
         return new FlatMapIntoIterable<T, U>(mapper);
     }
 
-    enum MapToInt implements Function<Object, Object> {
-        INSTANCE;
-        @Override
-        public Object apply(Object t) throws Exception {
-            return 0;
-        }
-    }
-
     public static <T> Callable<ConnectableFlowable<T>> replayCallable(final Flowable<T> parent) {
         return new Callable<ConnectableFlowable<T>>() {
             @Override

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

@@ -53,8 +53,6 @@ static final class EqualCoordinator<T> extends DeferredScalarSubscription<Boolea
 
         final BiPredicate<? super T, ? super T> comparer;
 
-        final int prefetch;
-
         final EqualSubscriber<T> first;
 
         final EqualSubscriber<T> second;
@@ -69,7 +67,6 @@ static final class EqualCoordinator<T> extends DeferredScalarSubscription<Boolea
 
         EqualCoordinator(Subscriber<? super Boolean> actual, int prefetch, BiPredicate<? super T, ? super T> comparer) {
             super(actual);
-            this.prefetch = prefetch;
             this.comparer = comparer;
             this.wip = new AtomicInteger();
             this.first = new EqualSubscriber<T>(this, prefetch);

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

@@ -25,11 +25,6 @@
 public final class FlowableToList<T, U extends Collection<? super T>> extends AbstractFlowableWithUpstream<T, U> {
     final Callable<U> collectionSupplier;
 
-    @SuppressWarnings("unchecked")
-    public FlowableToList(Publisher<T> source) {
-        this(source, (Callable<U>)ArrayListSupplier.asCallable());
-    }
-
     public FlowableToList(Publisher<T> source, Callable<U> collectionSupplier) {
         super(source);
         this.collectionSupplier = collectionSupplier;

src/main/java/io/reactivex/internal/schedulers/ScheduledRunnable.java

@@ -98,14 +98,6 @@ public void setFuture(Future<?> f) {
         }
     }
 
-    /**
-     * Returns true if this ScheduledRunnable has been scheduled.
-     * @return true if this ScheduledRunnable has been scheduled.
-     */
-    public boolean wasScheduled() {
-        return get(FUTURE_INDEX) != null;
-    }
-
     @Override
     public void dispose() {
         for (;;) {

src/main/java/io/reactivex/internal/subscribers/SubscriberResourceWrapper.java

@@ -29,8 +29,6 @@ public final class SubscriberResourceWrapper<T> extends AtomicReference<Disposab
 
     final AtomicReference<Subscription> subscription = new AtomicReference<Subscription>();
 
-    static final Object TERMINATED = new Object();
-
     public SubscriberResourceWrapper(Subscriber<? super T> actual) {
         this.actual = actual;
     }