4.x: Unit test lambdaification 8 of N (ReactiveX#8144)

Author: akarnokd

src/test/java/io/reactivex/rxjava4/flowable/FlowableNullTests.java

@@ -735,12 +735,7 @@ public void serializedSubjectOnErrorNull() {
 
     @Test(expected = NullPointerException.class)
     public void combineLatestDelayErrorIterableFunctionReturnsNull() {
-        Flowable.combineLatestDelayError(Arrays.asList(just1), new Function<Object[], Object>() {
-            @Override
-            public Object apply(Object[] v) {
-                return null;
-            }
-        }, 128).blockingLast();
+        Flowable.combineLatestDelayError(Arrays.asList(just1), _ -> null, 128).blockingLast();
     }
 
     @Test(expected = NullPointerException.class)

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

@@ -951,30 +951,24 @@ public void toObservableError() {
     @Test
     public void zipIterableObject() {
         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
-            public Object apply(Object[] o) throws Exception {
-                int sum = 0;
-                for (Object i : o) {
-                    sum += (Integer) i;
-                }
-                return sum;
+        Flowable.zip(flowables, o -> {
+            int sum = 0;
+            for (Object i : o) {
+                sum += (Integer) i;
             }
+            return sum;
         }).test().assertResult(2, 4, 6);
     }
 
     @Test
     public void combineLatestObject() {
         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
-            public Object apply(final Object[] o) throws Exception {
-                int sum = 1;
-                for (Object i : o) {
-                    sum *= (Integer) i;
-                }
-                return sum;
+        Flowable.combineLatest(flowables, o -> {
+            int sum = 1;
+            for (Object i : o) {
+                sum *= (Integer) i;
             }
+            return sum;
         }).test().assertResult(3, 6, 9);
     }
 }

src/test/java/io/reactivex/rxjava4/flowable/FlowableZipTests.java

@@ -79,13 +79,10 @@ public void nonBlockingObservable() {
 
         Collection<Flowable<Object>> observables = Collections.emptyList();
 
-        Flowable<Object> result = Flowable.zip(observables, new Function<Object[], Object>() {
-            @Override
-            public Object apply(Object[] args) {
-                System.out.println("received: " + args);
-                assertEquals("No argument should have been passed", 0, args.length);
-                return invoked;
-            }
+        Flowable<Object> result = Flowable.zip(observables, args -> {
+            System.out.println("received: " + args);
+            assertEquals("No argument should have been passed", 0, args.length);
+            return invoked;
         });
 
         assertSame(invoked, result.blockingLast());

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/BlockingFlowableNextTest.java

@@ -20,7 +20,6 @@
 import java.util.concurrent.atomic.*;
 
 import org.junit.*;
-import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.disposables.SerialDisposable;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableAmbTest.java

@@ -51,39 +51,35 @@ public void setUp() {
 
     private Flowable<String> createFlowable(final String[] values,
             final long interval, final Throwable e) {
-        return Flowable.unsafeCreate(new Publisher<String>() {
+        return Flowable.unsafeCreate(subscriber -> {
+            @SuppressWarnings("resource")
+            final CompositeDisposable parentSubscription = new CompositeDisposable();
 
-            @Override
-            public void subscribe(final Subscriber<? super String> subscriber) {
-                @SuppressWarnings("resource")
-                final CompositeDisposable parentSubscription = new CompositeDisposable();
-
-                subscriber.onSubscribe(new Subscription() /* NFI */ {
-                    @Override
-                    public void request(long n) {
+            subscriber.onSubscribe(new Subscription() /* NFI */ {
+                @Override
+                public void request(long n) {
 
-                    }
-
-                    @Override
-                    public void cancel() {
-                        parentSubscription.dispose();
-                    }
-                });
+                }
 
-                long delay = interval;
-                for (final String value : values) {
-                    parentSubscription.add(innerScheduler.schedule(() -> subscriber.onNext(value)
-                        , delay, TimeUnit.MILLISECONDS));
-                    delay += interval;
+                @Override
+                public void cancel() {
+                    parentSubscription.dispose();
                 }
-                parentSubscription.add(innerScheduler.schedule(() -> {
-                        if (e == null) {
-                            subscriber.onComplete();
-                        } else {
-                            subscriber.onError(e);
-                        }
-                }, delay, TimeUnit.MILLISECONDS));
+            });
+
+            long delay = interval;
+            for (final String value : values) {
+                parentSubscription.add(innerScheduler.schedule(() -> subscriber.onNext(value)
+                    , delay, TimeUnit.MILLISECONDS));
+                delay += interval;
             }
+            parentSubscription.add(innerScheduler.schedule(() -> {
+                    if (e == null) {
+                        subscriber.onComplete();
+                    } else {
+                        subscriber.onError(e);
+                    }
+            }, delay, TimeUnit.MILLISECONDS));
         });
     }