1.x: Remove some unused fields

src/main/java/rx/internal/operators/CompletableOnSubscribeConcat.java

@@ -45,7 +45,6 @@ public void call(CompletableSubscriber s) {
     static final class CompletableConcatSubscriber
     extends Subscriber<Completable> {
         final CompletableSubscriber actual;
-        final int prefetch;
         final SerialSubscription sr;
 
         final SpscArrayQueue<Completable> queue;
@@ -60,7 +59,6 @@ static final class CompletableConcatSubscriber
 
         public CompletableConcatSubscriber(CompletableSubscriber actual, int prefetch) {
             this.actual = actual;
-            this.prefetch = prefetch;
             this.queue = new SpscArrayQueue<Completable>(prefetch);
             this.sr = new SerialSubscription();
             this.inner = new ConcatInnerSubscriber();
@@ -149,4 +147,4 @@ public void onCompleted() {
             }
         }
     }
-}
+}

src/main/java/rx/internal/operators/CompletableOnSubscribeConcatIterable.java

@@ -61,8 +61,6 @@ static final class ConcatInnerSubscriber extends AtomicInteger implements Comple
         final CompletableSubscriber actual;
         final Iterator<? extends Completable> sources;
 
-        int index;
-
         final SerialSubscription sd;
 
         public ConcatInnerSubscriber(CompletableSubscriber actual, Iterator<? extends Completable> sources) {
@@ -132,4 +130,4 @@ void next() {
             } while (decrementAndGet() != 0);
         }
     }
-}
+}

src/main/java/rx/internal/operators/CompletableOnSubscribeMerge.java

@@ -50,7 +50,6 @@ static final class CompletableMergeSubscriber
     extends Subscriber<Completable> {
         final CompletableSubscriber actual;
         final CompositeSubscription set;
-        final int maxConcurrency;
         final boolean delayErrors;
 
         volatile boolean done;
@@ -63,7 +62,6 @@ static final class CompletableMergeSubscriber
 
         public CompletableMergeSubscriber(CompletableSubscriber actual, int maxConcurrency, boolean delayErrors) {
             this.actual = actual;
-            this.maxConcurrency = maxConcurrency;
             this.delayErrors = delayErrors;
             this.set = new CompositeSubscription();
             this.wip = new AtomicInteger(1);
@@ -211,4 +209,4 @@ public static Throwable collectErrors(Queue<Throwable> q) {
         }
         return new CompositeException(list);
     }
-}
+}

src/main/java/rx/internal/operators/OnSubscribeCombineLatest.java

@@ -89,7 +89,6 @@ static final class LatestCoordinator<T, R> extends AtomicInteger implements Prod
         private static final long serialVersionUID = 8567835998786448817L;
         final Subscriber<? super R> actual;
         final FuncN<? extends R> combiner;
-        final int count;
         final CombinerSubscriber<T, R>[] subscribers;
         final int bufferSize;
         final Object[] latest;
@@ -116,7 +115,6 @@ public LatestCoordinator(Subscriber<? 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 = new Object[count];