Fix get() conditional return

Resolves #591
This commit is contained in:
David Turanski
2020-09-25 10:14:39 -04:00
committed by Oleg Zhurakousky
parent 3b26ca1282
commit 22a9733eb4

View File

@@ -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);
}