tweak Mono.fromDirect

YiYangbuku · Jun 29, 2017 · 5b9942b · 5b9942b
1 parent 77e3b8b
commit 5b9942b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/Mono.java b/reactor-core/src/main/java/reactor/core/publisher/Mono.java
@@ -365,6 +365,11 @@ public static <T> Mono<T> fromCompletionStage(CompletionStage<? extends T> compl
 	 * @return a wrapped {@link Mono}
 	 */
 	public static <I> Mono<I> fromDirect(Publisher<? extends I> source){
+		if(source instanceof Mono){
+			@SuppressWarnings("unchecked")
+			Mono<I> m = (Mono<I>)source;
+			return m;
+		}
 		if(source instanceof Fuseable){
 			return new MonoSourceFuseable<>(source);
 		}