public Map getEndpoints()

in gremlin-client/src/main/java/software/amazon/neptune/cluster/GetCurrentEndpointsFromGremlinClient.java [37:47]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    public Map<? extends EndpointsSelector, EndpointCollection> getEndpoints(Map<? extends EndpointsSelector, Collection<GremlinClient>> clientSelectors, boolean refresh) {
        Map<EndpointsSelector, EndpointCollection> results = new HashMap<>();
        for (Map.Entry<? extends EndpointsSelector, Collection<GremlinClient>> clientSelector : clientSelectors.entrySet()) {
            Collection<Endpoint> endpoints = new ArrayList<>();
            for (GremlinClient client : clientSelector.getValue()) {
                endpoints.addAll(client.currentEndpoints().stream().collect(Collectors.toList()));
            }
            results.put(clientSelector.getKey(), new EndpointCollection(endpoints));
        }
        return results;
    }