From 53592469ebaae08c5893b06bf4c17fd425f885f3 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 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);
 		}