提交 780eea2e 编写于 作者: N Nikita Koksharov

refactoring

上级 e97e78fa
......@@ -193,7 +193,7 @@ abstract class ConnectionPool<T extends RedisConnection> {
iterator.remove();
}
}
while (!entriesCopy.isEmpty()) {
if (!entriesCopy.isEmpty()) {
ClientConnectionsEntry entry = config.getLoadBalancer().getEntry(entriesCopy);
return acquireConnection(command, entry);
}
......
......@@ -177,9 +177,7 @@ public class BaseTransactionalMap<K, V> {
}
operations.add(operation);
for (HashValue key : state.keySet()) {
state.put(key, MapEntry.NULL);
}
state.replaceAll((k, v) -> MapEntry.NULL);
deleted = true;
result.trySuccess(res);
});
......
......@@ -147,9 +147,7 @@ public abstract class BaseTransactionalSet<V> extends BaseTransactionalObject {
}
operations.add(operation);
for (HashValue key : state.keySet()) {
state.put(key, NULL);
}
state.replaceAll((k, v) -> NULL);
deleted = true;
result.trySuccess(res);
});
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册