private void update()

in registry-api/src/main/java/com/alibaba/dubbo/registry/kubernetes/KubernetesRegistry.java [109:125]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    private void update(Endpoints endpoints, final NotifyListener notifyListener, int targetPort) {
        List<URL> servers = new ArrayList<>();
        endpoints.getSubsets().stream().forEach(subset -> {
            long matchingPorts = subset.getPorts().stream().filter(p -> {
                return p.getPort() == targetPort;
            }).count();
            if (matchingPorts > 0) {
                subset.getAddresses().stream().map(address -> {
                    return new URL("", address.getIp(), targetPort);
                }).forEach(address -> {
                    servers.add(address);
                });
            }
        });

        notifyListener.notify(servers);
    }