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 266be8c23e
commit 53592469eb

View File

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