public CompletableFuture closeAsync()

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

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

    public CompletableFuture<Void> closeAsync() {

        if (closing.get() != null)
            return closing.get();

        List<CompletableFuture<Void>> futures = new ArrayList<>();

        for (Cluster cluster : clusters.values()) {
            futures.add(cluster.closeAsync());
        }
        futures.add(parentCluster.closeAsync());

        closing.set(CompletableFuture.allOf(futures.toArray(new CompletableFuture[]{})));

        return closing.get();
    }