Format

Author: thachlp

src/main/java/io/lettuce/core/cluster/ClusterTopologyRefreshScheduler.java

@@ -321,6 +321,7 @@ private static class ClusterTopologyRefreshTask extends AtomicBoolean implements
         private static final long serialVersionUID = -1337731371220365694L;
 
         private final Supplier<CompletionStage<?>> reloadTopologyAsync;
+
         private final CompletableFuture<Void> completionFuture = new CompletableFuture<>();
 
         ClusterTopologyRefreshTask(Supplier<CompletionStage<?>> reloadTopologyAsync) {

src/main/java/io/lettuce/core/cluster/RedisClusterClient.java

@@ -1159,7 +1159,7 @@ public CompletableFuture<Void> shutdownAsync(long quietPeriod, long timeout, Tim
                 .exceptionally(ex -> {
                     System.err.println("Error during topology refresh or shutdown: " + ex.getMessage());
                     return null;
-        });
+                });
     }
 
     // -------------------------------------------------------------------------