Converting the last bit of tests to Flow.*

Author: akarnokd

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

@@ -17,7 +17,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/jmh/java/io/reactivex/rxjava4/core/FlatMapJustPerf.java

@@ -17,7 +17,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/jmh/java/io/reactivex/rxjava4/core/InputWithIncrementingInteger.java

@@ -17,7 +17,7 @@
 
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.internal.subscriptions.EmptySubscription;
 import io.reactivex.rxjava4.subscribers.DefaultSubscriber;

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

@@ -16,7 +16,7 @@
 import java.lang.management.ManagementFactory;
 import java.util.concurrent.Callable;
 
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.disposables.Disposable;
 import io.reactivex.rxjava4.functions.*;
@@ -35,7 +35,7 @@ static long memoryUse() {
 
     static final class MyRx2Subscriber implements FlowableSubscriber<Object> {
 
-        org.reactivestreams.Subscription upstream;
+        Subscription upstream;
 
         @Override
         public void onSubscribe(Subscription s) {

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

@@ -16,7 +16,7 @@
 import java.util.concurrent.TimeUnit;
 
 import org.openjdk.jmh.annotations.*;
-import org.reactivestreams.Publisher;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.functions.Function;
 import io.reactivex.rxjava4.schedulers.Schedulers;

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

@@ -16,7 +16,7 @@
 import java.util.concurrent.CountDownLatch;
 
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.disposables.Disposable;
 

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

@@ -16,7 +16,7 @@
 import java.util.concurrent.CountDownLatch;
 
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 /**
  * Performance subscriber with a one-time request from the upstream.

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

@@ -14,7 +14,7 @@
 package io.reactivex.rxjava4.core;
 
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.disposables.Disposable;
 

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

@@ -16,7 +16,7 @@
 import java.util.concurrent.CountDownLatch;
 
 import org.openjdk.jmh.infra.Blackhole;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 @SuppressWarnings("exports")
 public class PerfSubscriber implements FlowableSubscriber<Object> {

src/jmh/java/io/reactivex/rxjava4/core/RxVsStreamPerf.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;