Use read-only view when consuming Partitions #1252

The node-selection API now uses the read-only view instead of the mutable partitions view when consuming the topology view.

src/main/java/io/lettuce/core/cluster/DynamicNodeSelection.java

@@ -66,6 +66,6 @@ protected CompletableFuture<API> getApi(RedisClusterNode redisClusterNode) {
 
     @Override
     protected List<RedisClusterNode> nodes() {
-        return writer.getPartitions().getPartitions().stream().filter(selector).collect(Collectors.toList());
+        return writer.getPartitions().stream().filter(selector).collect(Collectors.toList());
     }
 }

src/main/java/io/lettuce/core/cluster/RedisClusterPubSubAsyncCommandsImpl.java

@@ -131,7 +131,7 @@ private static class StaticPubSubAsyncNodeSelection<K, V>
         public StaticPubSubAsyncNodeSelection(StatefulRedisClusterPubSubConnection<K, V> globalConnection,
                 Predicate<RedisClusterNode> selector) {
 
-            this.redisClusterNodes = globalConnection.getPartitions().getPartitions().stream().filter(selector)
+            this.redisClusterNodes = globalConnection.getPartitions().stream().filter(selector)
                     .collect(Collectors.toList());
             writer = ((StatefulRedisClusterPubSubConnectionImpl) globalConnection).getClusterDistributionChannelWriter();
         }

src/main/java/io/lettuce/core/cluster/RedisClusterPubSubReactiveCommandsImpl.java

@@ -130,7 +130,7 @@ private static class StaticPubSubReactiveNodeSelection<K, V>
         public StaticPubSubReactiveNodeSelection(StatefulRedisClusterPubSubConnection<K, V> globalConnection,
                 Predicate<RedisClusterNode> selector) {
 
-            this.redisClusterNodes = globalConnection.getPartitions().getPartitions().stream().filter(selector)
+            this.redisClusterNodes = globalConnection.getPartitions().stream().filter(selector)
                     .collect(Collectors.toList());
             writer = ((StatefulRedisClusterPubSubConnectionImpl) globalConnection).getClusterDistributionChannelWriter();
         }

src/main/java/io/lettuce/core/cluster/StaticNodeSelection.java

@@ -48,7 +48,7 @@ public StaticNodeSelection(ClusterDistributionChannelWriter writer, Predicate<Re
         this.intent = intent;
         this.apiExtractor = apiExtractor;
 
-        this.redisClusterNodes = writer.getPartitions().getPartitions().stream().filter(selector).collect(Collectors.toList());
+        this.redisClusterNodes = writer.getPartitions().stream().filter(selector).collect(Collectors.toList());
     }
 
     @Override