void removeClustersWithNoMatchingEndpoint()

in gremlin-client/src/main/java/org/apache/tinkerpop/gremlin/driver/ClientClusterCollection.java [66:78]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    void removeClustersWithNoMatchingEndpoint(EndpointCollection endpoints, Function<Cluster, Void> clusterCloseMethod) {
        List<String> removalList = new ArrayList<>();
        for (String address : clusters.keySet()) {
            if (!endpoints.containsEndpoint(new DatabaseEndpoint().withAddress(address))) {
                removalList.add(address);
            }
        }
        for (String address : removalList) {
            logger.info("Removing client for {}", address);
            Cluster cluster = clusters.remove(address);
            clusterCloseMethod.apply(cluster);
        }
    }