Fix compile warnings

Author: akarnokd

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

@@ -21,7 +21,6 @@
 
 import io.reactivex.exceptions.Exceptions;
 import io.reactivex.functions.BooleanSupplier;
-import io.reactivex.internal.functions.ObjectHelper;
 import io.reactivex.internal.subscriptions.SubscriptionHelper;
 import io.reactivex.internal.util.*;
 import io.reactivex.plugins.RxJavaPlugins;

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

@@ -142,7 +142,7 @@ public void subscribeActual(Subscriber<? super R> s) {
             new FlowableMap<T, R>((Publisher<T>)a[0], new Function<T, R>() {
                 @Override
                 public R apply(T t) throws Exception {
-                    return combiner.apply((T[])new Object[] { t });
+                    return combiner.apply(new Object[] { t });
                 }
             }).subscribe(s);
             return;

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

@@ -19,7 +19,6 @@
 
 import io.reactivex.exceptions.Exceptions;
 import io.reactivex.functions.Function;
-import io.reactivex.internal.functions.ObjectHelper;
 import io.reactivex.internal.fuseable.*;
 import io.reactivex.internal.queue.SpscArrayQueue;
 import io.reactivex.internal.subscriptions.*;

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

@@ -21,7 +21,6 @@
 
 import io.reactivex.exceptions.*;
 import io.reactivex.functions.Function;
-import io.reactivex.internal.functions.ObjectHelper;
 import io.reactivex.internal.fuseable.*;
 import io.reactivex.internal.queue.SpscArrayQueue;
 import io.reactivex.internal.subscriptions.*;

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

@@ -20,7 +20,6 @@
 import io.reactivex.Scheduler;
 import io.reactivex.Scheduler.Worker;
 import io.reactivex.exceptions.*;
-import io.reactivex.internal.functions.ObjectHelper;
 import io.reactivex.internal.fuseable.*;
 import io.reactivex.internal.queue.SpscArrayQueue;
 import io.reactivex.internal.subscriptions.*;

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

@@ -42,10 +42,9 @@ protected void subscribeActual(MaybeObserver<? super R> observer) {
 
         if (n == 1) {
             sources[0].subscribe(new MaybeMap.MapMaybeObserver<T, R>(observer, new Function<T, R>() {
-                @SuppressWarnings("unchecked")
                 @Override
                 public R apply(T t) throws Exception {
-                    return zipper.apply((T[])new Object[] { t });
+                    return zipper.apply(new Object[] { t });
                 }
             }));
             return;
@@ -104,14 +103,13 @@ public void dispose() {
             }
         }
 
-        @SuppressWarnings("unchecked")
         void innerSuccess(T value, int index) {
             values[index] = value;
             if (decrementAndGet() == 0) {
                 R v;
 
                 try {
-                    v = ObjectHelper.requireNonNull(zipper.apply((T[])values), "The zipper returned a null value");
+                    v = ObjectHelper.requireNonNull(zipper.apply(values), "The zipper returned a null value");
                 } catch (Throwable ex) {
                     Exceptions.throwIfFatal(ex);
                     actual.onError(ex);

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

@@ -58,10 +58,9 @@ protected void subscribeActual(MaybeObserver<? super R> observer) {
 
         if (n == 1) {
             a[0].subscribe(new MaybeMap.MapMaybeObserver<T, R>(observer, new Function<T, R>() {
-                @SuppressWarnings("unchecked")
                 @Override
                 public R apply(T t) throws Exception {
-                    return zipper.apply((T[])new Object[] { t });
+                    return zipper.apply(new Object[] { t });
                 }
             }));
             return;

src/test/java/io/reactivex/flowable/FlowableTests.java

@@ -1063,6 +1063,7 @@ public void toObservableError() {
 
     @Test
     public void zipIterableObject() {
+        @SuppressWarnings("unchecked")
         final List<Flowable<Integer>> flowables = Arrays.asList(Flowable.just(1, 2, 3), Flowable.just(1, 2, 3));
         Flowable.zip(flowables, new Function<Object[], Object>() {
             @Override
@@ -1078,6 +1079,7 @@ public Object apply(Object[] o) throws Exception {
 
     @Test
     public void combineLatestObject() {
+        @SuppressWarnings("unchecked")
         final List<Flowable<Integer>> flowables = Arrays.asList(Flowable.just(1, 2, 3), Flowable.just(1, 2, 3));
         Flowable.combineLatest(flowables, new Function<Object[], Object>() {
             @Override

src/test/java/io/reactivex/maybe/MaybeTest.java

@@ -2860,6 +2860,7 @@ public void ambWith2SignalsSuccess() {
 
     @Test
     public void zipIterableObject() {
+        @SuppressWarnings("unchecked")
         final List<Maybe<Integer>> maybes = Arrays.asList(Maybe.just(1), Maybe.just(4));
         Maybe.zip(maybes, new Function<Object[], Object>() {
             @Override

src/test/java/io/reactivex/observable/ObservableTest.java

@@ -1059,6 +1059,7 @@ public void singleDefault() {
 
     @Test
     public void zipIterableObject() {
+        @SuppressWarnings("unchecked")
         final List<Observable<Integer>> observables = Arrays.asList(Observable.just(1, 2, 3), Observable.just(1, 2, 3));
         Observable.zip(observables, new Function<Object[], Object>() {
             @Override
@@ -1074,6 +1075,7 @@ public Object apply(Object[] o) throws Exception {
 
     @Test
     public void combineLatestObject() {
+        @SuppressWarnings("unchecked")
         final List<Observable<Integer>> observables = Arrays.asList(Observable.just(1, 2, 3), Observable.just(1, 2, 3));
         Observable.combineLatest(observables, new Function<Object[], Object>() {
             @Override