From 1f79c80171d6d8dc1035d8ea69cb8c88fbbbf9a6 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Tue, 22 Sep 2020 08:35:07 +0300
Subject: [PATCH] refactoring
---
.../org/redisson/cluster/ClusterConnectionManager.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
index 19cdfb431..ac3a5e347 100644
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@@ -674,10 +674,10 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
addedSlots.andNot(currentPartition.slots());
currentPartition.addSlots(addedSlots);
- for (Integer slot : (Iterable<Integer>) addedSlots.stream()::iterator) {
+ addedSlots.stream().forEach(slot -> {
addEntry(slot, entry);
lastPartitions.put(slot, currentPartition);
- }
+ });
if (!addedSlots.isEmpty()) {
log.info("{} slots added to {}", addedSlots.cardinality(), currentPartition.getMasterAddress());
}
@@ -686,12 +686,11 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
removedSlots.andNot(newPartition.slots());
currentPartition.removeSlots(removedSlots);
- for (Integer removeSlot : (Iterable<Integer>) removedSlots.stream()::iterator) {
+ removedSlots.stream().forEach(removeSlot -> {
if (lastPartitions.remove(removeSlot, currentPartition)) {
removeEntry(removeSlot);
}
- }
-
+ });
if (!removedSlots.isEmpty()) {
log.info("{} slots removed from {}", removedSlots.cardinality(), currentPartition.getMasterAddress());
}