4.x: Unit test lambdaification 6 of N (ReactiveX#8142)

Author: akarnokd

src/test/java/io/reactivex/rxjava4/core/ConverterTest.java

@@ -194,7 +194,7 @@ interface B<T> { }
     }
 
     private static <T> ParallelFlowableConverter<A<T, ?>, B<T>> testParallelFlowableConverterCreator() {
-        return a -> new B<T>() /* NFI */ {
+        return _ -> new B<T>() /* NFI */ {
         };
     }
 

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

@@ -19,10 +19,8 @@
 import java.util.concurrent.Flow.Publisher;
 
 import org.junit.Test;
-import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
-import io.reactivex.rxjava4.flowable.FlowableCovarianceTest.Movie;
 import io.reactivex.rxjava4.flowables.GroupedFlowable;
 import io.reactivex.rxjava4.functions.*;
 import io.reactivex.rxjava4.testsupport.TestSubscriberEx;

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

@@ -21,7 +21,6 @@
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.TestException;
-import io.reactivex.rxjava4.functions.*;
 
 public class FlowableDoOnTest extends RxJavaTest {
 

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

@@ -14,7 +14,6 @@
 package io.reactivex.rxjava4.flowable;
 
 import org.junit.Test;
-import static java.util.concurrent.Flow.*;
 
 import java.util.concurrent.Flow.Publisher;
 

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

@@ -19,7 +19,6 @@
 import java.util.concurrent.Flow.Publisher;
 
 import org.junit.Test;
-import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.flowable.FlowableCovarianceTest.*;

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

@@ -21,7 +21,6 @@
 import java.util.concurrent.Flow.Publisher;
 
 import org.junit.*;
-import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.*;

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

@@ -24,7 +24,6 @@
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.disposables.Disposable;
 import io.reactivex.rxjava4.exceptions.*;
-import io.reactivex.rxjava4.functions.*;
 import io.reactivex.rxjava4.internal.functions.Functions;
 import io.reactivex.rxjava4.internal.subscribers.ForEachWhileSubscriber;
 import io.reactivex.rxjava4.internal.subscriptions.BooleanSubscription;
@@ -616,7 +615,7 @@ public void onCompleteThrows() {
     public void subscribeConsumerConsumerWithError() {
         final List<Integer> list = new ArrayList<>();
 
-        Flowable.<Integer>error(new TestException()).subscribe(v -> list.add(v), e -> list.add(100));
+        Flowable.<Integer>error(new TestException()).subscribe(v -> list.add(v), _ -> list.add(100));
 
         assertEquals(Arrays.asList(100), list);
     }

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

@@ -19,7 +19,6 @@
 import java.util.concurrent.Flow.Publisher;
 
 import org.junit.Test;
-import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.flowable.FlowableCovarianceTest.*;

src/test/java/io/reactivex/rxjava4/internal/jdk8/ParallelMapOptionalTest.java

@@ -22,7 +22,6 @@
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.TestException;
-import io.reactivex.rxjava4.functions.*;
 import io.reactivex.rxjava4.internal.functions.Functions;
 import io.reactivex.rxjava4.parallel.*;
 import io.reactivex.rxjava4.plugins.RxJavaPlugins;

src/test/java/io/reactivex/rxjava4/internal/observers/LambdaObserverTest.java

@@ -25,7 +25,6 @@
 import io.reactivex.rxjava4.core.RxJavaTest;
 import io.reactivex.rxjava4.disposables.*;
 import io.reactivex.rxjava4.exceptions.*;
-import io.reactivex.rxjava4.functions.*;
 import io.reactivex.rxjava4.internal.functions.Functions;
 import io.reactivex.rxjava4.plugins.RxJavaPlugins;
 import io.reactivex.rxjava4.subjects.PublishSubject;