From 22a9733eb449dc3031e20c6ede8b8dcfac7f275c Mon Sep 17 00:00:00 2001
From: David Turanski <dturanski@vmware.com>
Date: Fri, 25 Sep 2020 10:14:39 -0400
Subject: [PATCH] Fix get() conditional return

Resolves #591
---
 .../cloud/function/context/catalog/SimpleFunctionRegistry.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 9f57b9376..135f7265e 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
@@ -503,7 +503,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);
 		}