diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
index 8daf02697..3659c776a 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
@@ -478,7 +478,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
 		public Object get(Function<Message, Message> enricher) {
 			Object input = FunctionTypeUtils.isMono(this.functionType)
 				? Mono.empty()
-				: (FunctionTypeUtils.isMono(this.functionType) ? Flux.empty() : null);
+				: (FunctionTypeUtils.isFlux(this.functionType) ? Flux.empty() : null);
 
 			return this.doApply(input, false, enricher);
 		}