diff --git a/reactor-core/src/test/java/reactor/core/publisher/MonoFirstWithValueTest.java b/reactor-core/src/test/java/reactor/core/publisher/MonoFirstWithValueTest.java index 61353ec259..4a37e099ac 100644 --- a/reactor-core/src/test/java/reactor/core/publisher/MonoFirstWithValueTest.java +++ b/reactor-core/src/test/java/reactor/core/publisher/MonoFirstWithValueTest.java @@ -20,14 +20,11 @@ import java.util.Arrays; import java.util.List; import java.util.NoSuchElementException; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.atomic.AtomicLong; import org.junit.jupiter.api.Test; import reactor.core.Exceptions; import reactor.core.Scannable; -import reactor.core.scheduler.Schedulers; import reactor.test.StepVerifier; import reactor.test.publisher.TestPublisher; import reactor.test.subscriber.AssertSubscriber; @@ -175,35 +172,6 @@ void cancelIsPropagated() { pub2.assertMaxRequested(1); pub2.assertWasCancelled(); } - @Test - void cancelInflightMono() { - AtomicLong cancelledInflightMonos = new AtomicLong(0); - CountDownLatch inflightMonoLatch = new CountDownLatch(1); - CountDownLatch completedMonoLatch = new CountDownLatch(1); - Mono inflightMono1 = Mono.fromCallable(() -> { - inflightMonoLatch.await(); - return 1; - }).doOnCancel(cancelledInflightMonos::getAndIncrement).subscribeOn(Schedulers.boundedElastic()); - - Mono inflightMono2 = Mono.fromCallable(() -> { - inflightMonoLatch.await(); - return 2; - }).doOnCancel(cancelledInflightMonos::getAndIncrement).subscribeOn(Schedulers.boundedElastic()); - - Mono completedMono = Mono.fromCallable(() -> { - completedMonoLatch.await(); - return 3; - }).doOnCancel(cancelledInflightMonos::getAndIncrement).subscribeOn(Schedulers.boundedElastic()); - - StepVerifier.create(Mono.firstWithValue(inflightMono1, inflightMono2, completedMono)) - .then(() -> { - completedMonoLatch.countDown(); - }) - .expectNext(3) - .verifyComplete(); - - assertThat(cancelledInflightMonos).hasValue(2); - } @Test void singleArrayNullSource() {