minor cleanup

jrhee17 · Jan 20, 2025 · 23d5191 · 23d5191
1 parent 7befff4
commit 23d5191
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/xds/src/main/java/com/linecorp/armeria/xds/client/endpoint/ClusterEntry.java b/xds/src/main/java/com/linecorp/armeria/xds/client/endpoint/ClusterEntry.java
@@ -45,14 +45,7 @@ public final class ClusterEntry extends AbstractListenable<XdsLoadBalancer> impl
     @Nullable
     private final LocalCluster localCluster;
     private final EventExecutor eventExecutor;
-    private boolean closing;
-    private final FunctionSelector<XdsLoadBalancer> lbSelector = new FunctionSelector<>(ctx -> {
-        final XdsLoadBalancer loadBalancer = this.loadBalancer;
-        if (loadBalancer == null) {
-            return null;
-        }
-        return loadBalancer;
-    });
+    private final FunctionSelector<XdsLoadBalancer> lbSelector = new FunctionSelector<>(ctx -> loadBalancer);
     private int refCnt;
 
     public ClusterEntry(EventExecutor eventExecutor, @Nullable LocalCluster localCluster) {
@@ -71,7 +64,7 @@ public UpdatableLoadBalancer updateClusterSnapshot(ClusterSnapshot clusterSnapsh
         }
         final UpdatableLoadBalancer updatableLoadBalancer =
                 new UpdatableLoadBalancer(clusterSnapshot, localCluster, localLoadBalancer,
-                                          loadBalancer -> this.notifyListeners(loadBalancer));
+                                          this::notifyListeners);
         loadBalancer = updatableLoadBalancer;
         endpointsPool.updateClusterSnapshot(updatableLoadBalancer);
         lbSelector.refresh();
@@ -108,7 +101,6 @@ List<Endpoint> allEndpoints() {
 
     @Override
     public CompletableFuture<?> closeAsync() {
-        closing = true;
         if (localCluster != null) {
             localCluster.clusterEntry().removeListener(localClusterEntryListener);
         }