From 017665b9d93f0c23c76bb7c0e078f616dea8835e Mon Sep 17 00:00:00 2001 From: Stan <352435892@qq.com> Date: Wed, 19 Apr 2023 16:44:06 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#42]=20=E6=B2=A1=E6=9C=89=E5=8F=AF?= =?UTF-8?q?=E7=94=A8=E6=9C=8D=E5=8A=A1=E6=97=B6=EF=BC=8C=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E7=BA=BF=E7=A8=8B=E4=BC=9Ahang=E4=BD=8F=20(#43)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: zhaojian15 --- .../grpc/resolver/PolarisNameResolver.java | 26 +++++++++---------- 1 file changed, 12 insertions(+), 14 deletions(-) diff --git a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java index 1a80717..7313325 100644 --- a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java +++ b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java @@ -149,23 +149,21 @@ private void doWatch(Listener2 listener) { private void notifyListener(Listener2 listener, InstancesResponse response) { ServiceInstances serviceInstances = response.toServiceInstances(); - if (!serviceInstances.getInstances().isEmpty()) { - List equivalentAddressGroups = serviceInstances.getInstances() - .stream() - .map(this::buildEquivalentAddressGroup) - .collect(Collectors.toList()); + List equivalentAddressGroups = serviceInstances.getInstances() + .stream() + .map(this::buildEquivalentAddressGroup) + .collect(Collectors.toList()); - Attributes.Builder builder = Attributes.newBuilder(); + Attributes.Builder builder = Attributes.newBuilder(); - if (sourceService != null) { - builder.set(Common.SOURCE_SERVICE_INFO, sourceService); - } - - listener.onResult(ResolutionResult.newBuilder() - .setAddresses(equivalentAddressGroups) - .setAttributes(builder.build()) - .build()); + if (sourceService != null) { + builder.set(Common.SOURCE_SERVICE_INFO, sourceService); } + + listener.onResult(ResolutionResult.newBuilder() + .setAddresses(equivalentAddressGroups) + .setAttributes(builder.build()) + .build()); } @Override