SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove extraneous if() clause

Browse Source
This commit is contained in:
Dave Syer
2018-07-23 14:17:20 +01:00
parent 41520c4ce4
commit a840689c95
2 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/flux/FunctionController.java
View File

@@ -96,8 +96,7 @@ public class FunctionController {
if (logger.isDebugEnabled()) {
logger.debug("Handled POST with function");
}
return ResponseEntity.ok()
.body(response(request, function, single, result));
return ResponseEntity.ok().body(response(request, function, single, result));
}
if (consumer != null) {
@@ -175,9 +174,8 @@ public class FunctionController {
result = response(request, supplier, true, supplier(supplier));
}
if (inspector.isMessage(function)) {
if (inspector.isMessage(function)) {
result = Flux.from(result).map(message -> MessageUtils.unpack(function, message));
}
result = Flux.from(result)
.map(message -> MessageUtils.unpack(function, message));
}
return ResponseEntity.ok().body(result);
}

2
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/HeaderUtils.java
View File

@@ -17,10 +17,8 @@ package org.springframework.cloud.function.web.util;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;
import org.springframework.http.HttpHeaders;
import org.springframework.messaging.MessageHeaders;