This is an automated email from the ASF dual-hosted git repository.
xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new f1aaa20c3 keep the style consistent (#4279)
f1aaa20c3 is described below
commit f1aaa20c3cb8810bd877dba4cb340aa1959b3fc9
Author: mahaitao <[email protected]>
AuthorDate: Fri Dec 23 10:05:35 2022 +0800
keep the style consistent (#4279)
* keep the style consistent
* feat:fix
Co-authored-by: mahaitao617 <[email protected]>
---
.../org/apache/shenyu/loadbalancer/cache/UpstreamCacheManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/shenyu-loadbalancer/src/main/java/org/apache/shenyu/loadbalancer/cache/UpstreamCacheManager.java
b/shenyu-loadbalancer/src/main/java/org/apache/shenyu/loadbalancer/cache/UpstreamCacheManager.java
index 526d2069d..75854cf08 100644
---
a/shenyu-loadbalancer/src/main/java/org/apache/shenyu/loadbalancer/cache/UpstreamCacheManager.java
+++
b/shenyu-loadbalancer/src/main/java/org/apache/shenyu/loadbalancer/cache/UpstreamCacheManager.java
@@ -132,13 +132,13 @@ public final class UpstreamCacheManager {
}
/**
- * Submit.
+ * Submit .
*
* @param selectorId the selector id
* @param upstreamList the upstream list
*/
public void submit(final String selectorId, final List<Upstream>
upstreamList) {
- List<Upstream> validUpstreamList =
upstreamList.stream().filter(upstream ->
upstream.isStatus()).collect(Collectors.toList());
+ List<Upstream> validUpstreamList =
upstreamList.stream().filter(Upstream::isStatus).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(validUpstreamList)) {
List<Upstream> existUpstream =
UPSTREAM_MAP.computeIfAbsent(selectorId, k -> Lists.newArrayList());
existUpstream.stream().filter(upstream ->
!validUpstreamList.contains(upstream))