Simplify if/else in Azure function invoker

This commit is contained in:
onobc
2022-03-01 13:54:31 -06:00
committed by Oleg Zhurakousky
parent b9b3f7adf6
commit 0dca334614
2 changed files with 4 additions and 5 deletions

View File

@@ -20,8 +20,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version> <java.version>1.8</java.version>
<azure.functions.java.core.version>1.2.2 <azure.functions.java.core.version>1.2.2</azure.functions.java.core.version>
</azure.functions.java.core.version>
</properties> </properties>
<dependencies> <dependencies>

View File

@@ -128,10 +128,10 @@ public class FunctionInvoker<I, O> {
Object functionResult = function.apply(enhancedInput); Object functionResult = function.apply(enhancedInput);
if (!(functionResult instanceof Publisher)) { if (functionResult instanceof Publisher) {
return postProcessImperativeFunctionResult(input, enhancedInput, functionResult, function, executionContext); return postProcessReactiveFunctionResult(input, enhancedInput, (Publisher<?>) functionResult, function, executionContext);
} }
return postProcessReactiveFunctionResult(input, enhancedInput, (Publisher<?>) functionResult, function, executionContext); return postProcessImperativeFunctionResult(input, enhancedInput, functionResult, function, executionContext);
} }
/** /**