From eb319e525a9c357b270cf4d143f65845db8712a0 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 25 Mar 2021 14:28:18 +0100 Subject: [PATCH] GH-668 Initial NPE fix in RequestProcessor when no path argument provided --- .../cloud/function/web/RequestProcessor.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java index ab8a246a9..b2d18de9a 100644 --- a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java +++ b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java @@ -277,9 +277,14 @@ public class RequestProcessor { } private Publisher invokeFunction(FunctionWrapper wrapper) { - Flux input = Flux.from(wrapper.argument); - Object result = FunctionWebUtils.invokeFunction(wrapper.function, input, wrapper.function.isInputTypeMessage()); - return Mono.from((Publisher) result); + if (wrapper.argument != null) { + Flux input = Flux.from(wrapper.argument); + Object result = FunctionWebUtils.invokeFunction(wrapper.function, input, wrapper.function.isInputTypeMessage()); + return Mono.from((Publisher) result); + } + else { + return Mono.empty(); + } } /**