Resolves #820
This commit is contained in:
Oleg Zhurakousky
2022-03-08 14:56:51 +01:00
parent 42da405a18
commit bcbbbd3363

View File

@@ -121,7 +121,6 @@ public class FunctionInvoker<I, O> {
return function;
}
@SuppressWarnings({"unchecked", "rawtypes"})
public O handleRequest(I input, ExecutionContext executionContext) {
String functionDefinition = executionContext.getFunctionName();
FunctionInvocationWrapper function = this.discoverFunction(functionDefinition);
@@ -149,6 +148,7 @@ public class FunctionInvoker<I, O> {
* @param executionContext the Azure execution context
* @return the possibly modified function results
*/
@SuppressWarnings("unchecked")
protected O postProcessImperativeFunctionResult(I rawInputs, Object functionInputs, Object functionResult,
FunctionInvocationWrapper function, ExecutionContext executionContext
) {
@@ -193,6 +193,7 @@ public class FunctionInvoker<I, O> {
* @param executionContext the Azure execution context
* @return the possibly modified function results
*/
@SuppressWarnings("unchecked")
protected O postProcessMonoFunctionResult(I rawInputs, Object functionInputs, Mono<?> functionResult,
FunctionInvocationWrapper function, ExecutionContext executionContext
) {
@@ -213,6 +214,7 @@ public class FunctionInvoker<I, O> {
* @param executionContext the Azure execution context
* @return the possibly modified function results
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
protected O postProcessFluxFunctionResult(I rawInputs, Object functionInputs, Flux<?> functionResult,
FunctionInvocationWrapper function, ExecutionContext executionContext
) {