More TCK conversions

Author: akarnokd

src/jmh/java/io/reactivex/rxjava4/core/BinaryFlatMapPerf.java

@@ -18,7 +18,7 @@
 
 import org.openjdk.jmh.annotations.*;
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.Publisher;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.functions.Function;
 

src/test/java/io/reactivex/rxjava4/internal/subscribers/BasicFuseableConditionalSubscriberTest.java

@@ -18,7 +18,7 @@
 import static org.mockito.Mockito.*;
 
 import org.junit.Test;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.core.*;

src/test/java/io/reactivex/rxjava4/internal/subscribers/BlockingSubscriberTest.java

@@ -19,7 +19,7 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.junit.Test;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.RxJavaTest;
 import io.reactivex.rxjava4.internal.subscriptions.BooleanSubscription;

src/test/java/io/reactivex/rxjava4/internal/subscribers/BoundedSubscriberTest.java

@@ -18,7 +18,7 @@
 import java.util.*;
 
 import org.junit.Test;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.*;

src/test/java/io/reactivex/rxjava4/internal/subscribers/DeferredScalarSubscriberTest.java

@@ -20,7 +20,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.junit.Test;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.core.Scheduler.Worker;

src/test/java/io/reactivex/rxjava4/internal/subscribers/FlowableConsumersTest.java

@@ -35,7 +35,7 @@
 import java.util.*;
 
 import org.junit.Test;
-import org.reactivestreams.Subscriber;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.disposables.*;

src/test/java/io/reactivex/rxjava4/internal/subscribers/InnerQueuedSubscriberTest.java

@@ -18,7 +18,7 @@
 import java.util.*;
 
 import org.junit.Test;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.RxJavaTest;
 

src/test/java/io/reactivex/rxjava4/internal/subscribers/LambdaSubscriberTest.java

@@ -18,7 +18,7 @@
 import java.util.*;
 
 import org.junit.Test;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.*;

src/test/java/io/reactivex/rxjava4/internal/subscribers/QueueDrainSubscriberTest.java

@@ -18,7 +18,7 @@
 import java.util.List;
 
 import org.junit.Test;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.RxJavaTest;
 import io.reactivex.rxjava4.disposables.*;

src/test/java/io/reactivex/rxjava4/internal/subscribers/StrictSubscriberTest.java

@@ -18,7 +18,7 @@
 import java.util.*;
 
 import org.junit.Test;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.core.*;
 import io.reactivex.rxjava4.exceptions.TestException;