Refactoring tests

reactor · Sep 28, 2023 · 131b312 · 131b312
1 parent 36af5ae
commit 131b312
Show file tree

Hide file tree

Showing 2 changed files with 450 additions and 633 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/MonoDelayUntil.java b/reactor-core/src/main/java/reactor/core/publisher/MonoDelayUntil.java
@@ -94,7 +94,7 @@ MonoDelayUntil<T> copyWithNewTriggerGenerator(boolean delayError,
 	@Override
 	public void subscribe(CoreSubscriber<? super T> actual) {
 		try {
-			source.subscribe(subscribeOrReturn(actual));
+			Operators.toFluxOrMono(source).subscribe(subscribeOrReturn(actual));
 		}
 		catch (Throwable e) {
 			Operators.error(actual, Operators.onOperatorError(e, actual.currentContext()));