From 5f3f0cf965e39aca1154a83f42612d0988d6a349 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 29 Apr 2020 15:19:12 +0200 Subject: [PATCH] Polishing Fix code format Resolves #489 --- .../cloud/function/web/RequestProcessor.java | 6 ++++-- .../cloud/function/web/flux/FunctionController.java | 3 +-- 2 files changed, 5 insertions(+), 4 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 31e4e434b..4895bbd09 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 @@ -215,9 +215,11 @@ public class RequestProcessor { if (Collection.class .isAssignableFrom(this.inspector.getInputType(wrapper.handler()))) { flux = Flux.just(body); - } else if (body instanceof Flux) { + } + else if (body instanceof Flux) { flux = Flux.from((Flux) body); - } else { + } + else { Iterable iterable = body instanceof Collection ? (Collection) body : (body instanceof Set ? Collections.singleton(body) : Collections.singletonList(body)); diff --git a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/flux/FunctionController.java b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/flux/FunctionController.java index d46d9aba3..3b8d2d402 100644 --- a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/flux/FunctionController.java +++ b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/flux/FunctionController.java @@ -100,8 +100,7 @@ public class FunctionController { @PostMapping(path = "/**", produces = MediaType.TEXT_EVENT_STREAM_VALUE) @ResponseBody - public Mono> postStream(ServerWebExchange request, - @RequestBody(required = false) Flux body) { + public Mono> postStream(ServerWebExchange request, @RequestBody(required = false) Flux body) { final FunctionWrapper wrapper = wrapper(request); return this.processor.response(wrapper, body, true); }