-> import static java.util.concurrent.Flow.*; 1

Author: akarnokd

build.gradle

@@ -39,15 +39,13 @@ repositories {
 }
 
 dependencies {
-    api "org.reactivestreams:reactive-streams:$reactiveStreamsVersion"
-    jmh "org.reactivestreams:reactive-streams:$reactiveStreamsVersion"
-
     testImplementation "junit:junit:$junitVersion"
     testImplementation "org.mockito:mockito-core:$mockitoVersion"
 
     testImplementation "org.reactivestreams:reactive-streams-tck:$reactiveStreamsVersion"
     testImplementation "org.testng:testng:$testNgVersion"
     testImplementation "com.google.guava:guava:$guavaVersion"
+    testImplementation "org.reactivestreams:reactive-streams-tck-flow:$reactiveStreamsVersion"
 
     testImplementation "org.junit.jupiter:junit-jupiter:$jupiterVersion"
     testRuntimeOnly "org.junit.vintage:junit-vintage-engine:$jupiterVersion"

src/main/java/io/reactivex/rxjava4/core/Completable.java

@@ -16,7 +16,7 @@
 import java.util.*;
 import java.util.concurrent.*;
 
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.disposables.*;

src/main/java/io/reactivex/rxjava4/core/Flowable.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.*;
 import java.util.stream.*;
 
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.disposables.*;

src/main/java/io/reactivex/rxjava4/core/FlowableOperator.java

@@ -13,7 +13,7 @@
 
 package io.reactivex.rxjava4.core;
 
-import org.reactivestreams.Subscriber;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.NonNull;
 

src/main/java/io/reactivex/rxjava4/core/FlowableSubscriber.java

@@ -13,7 +13,7 @@
 
 package io.reactivex.rxjava4.core;
 
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.NonNull;
 

src/main/java/io/reactivex/rxjava4/core/FlowableTransformer.java

@@ -13,7 +13,7 @@
 
 package io.reactivex.rxjava4.core;
 
-import org.reactivestreams.Publisher;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.NonNull;
 

src/main/java/io/reactivex/rxjava4/core/Maybe.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.*;
 import java.util.stream.*;
 
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.disposables.*;

src/main/java/io/reactivex/rxjava4/core/Observable.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.*;
 import java.util.stream.*;
 
-import org.reactivestreams.Publisher;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.disposables.*;

src/main/java/io/reactivex/rxjava4/core/Single.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.*;
 import java.util.stream.*;
 
-import org.reactivestreams.*;
+import static java.util.concurrent.Flow.*;
 
 import io.reactivex.rxjava4.annotations.*;
 import io.reactivex.rxjava4.disposables.*;

src/main/java/io/reactivex/rxjava4/disposables/Disposable.java

@@ -17,7 +17,7 @@
 import io.reactivex.rxjava4.functions.Action;
 import io.reactivex.rxjava4.internal.disposables.EmptyDisposable;
 import io.reactivex.rxjava4.internal.functions.Functions;
-import org.reactivestreams.Subscription;
+import static java.util.concurrent.Flow.*;
 
 import java.util.Objects;
 import java.util.concurrent.Future;