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 a0d96ffbda
commit 42da405a18
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

@@ -129,10 +129,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);
} }
/** /**