Revert "Add MonoFirstWithValue inflight cancellation test (#3915)" (#…

…3934)

This reverts commit 3ba3cc1.

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<Integer> inflightMono1 = Mono.fromCallable(() -> {
-			inflightMonoLatch.await();
-			return 1;
-		}).doOnCancel(cancelledInflightMonos::getAndIncrement).subscribeOn(Schedulers.boundedElastic());
-
-		Mono<Integer> inflightMono2 = Mono.fromCallable(() -> {
-			inflightMonoLatch.await();
-			return 2;
-		}).doOnCancel(cancelledInflightMonos::getAndIncrement).subscribeOn(Schedulers.boundedElastic());
-
-		Mono<Integer> 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() {