diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 7ed659bbc..b40b03202 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -1,5 +1,5 @@ [versions] -reactorCore = "3.5.5-SNAPSHOT" +reactorCore = "3.6.0-SNAPSHOT" # Other shared versions reactiveStreams = "1.0.4" swt = "4.5.2" diff --git a/reactor-adapter/src/test/java/reactor/adapter/rxjava/RxJava3AdapterTest.java b/reactor-adapter/src/test/java/reactor/adapter/rxjava/RxJava3AdapterTest.java index 0dc35eef6..72d5a0fb1 100644 --- a/reactor-adapter/src/test/java/reactor/adapter/rxjava/RxJava3AdapterTest.java +++ b/reactor-adapter/src/test/java/reactor/adapter/rxjava/RxJava3AdapterTest.java @@ -17,34 +17,22 @@ package reactor.adapter.rxjava; import java.io.IOException; -import java.lang.reflect.Field; import java.util.List; import java.util.NoSuchElementException; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CountDownLatch; -import java.util.concurrent.Executors; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; -import java.util.concurrent.atomic.AtomicReference; import io.reactivex.rxjava3.annotations.NonNull; import io.reactivex.rxjava3.core.Completable; import io.reactivex.rxjava3.core.Flowable; import io.reactivex.rxjava3.core.Maybe; import io.reactivex.rxjava3.core.Single; -import io.reactivex.rxjava3.operators.QueueSubscription; import io.reactivex.rxjava3.internal.subscribers.BasicFuseableSubscriber; -import io.reactivex.rxjava3.observers.BaseTestConsumer; import io.reactivex.rxjava3.schedulers.Schedulers; import io.reactivex.rxjava3.subscribers.TestSubscriber; -import jdk.nashorn.internal.objects.NativeFloat32Array; import org.junit.Test; -import org.reactivestreams.Subscriber; -import org.reactivestreams.Subscription; - import reactor.core.Fuseable; -import reactor.core.publisher.BaseSubscriber; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.core.scheduler.Scheduler;