From fc1487168e16a73be5bab97e6da0f0318c17b85e Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Fri, 5 Jan 2024 09:30:32 +0300 Subject: [PATCH] refactoring --- .../main/java/org/redisson/client/RedisConnection.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/RedisConnection.java b/redisson/src/main/java/org/redisson/client/RedisConnection.java index 6e9c29e6f..2525f2237 100644 --- a/redisson/src/main/java/org/redisson/client/RedisConnection.java +++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java @@ -33,10 +33,7 @@ import org.slf4j.LoggerFactory; import java.util.Deque; import java.util.Queue; -import java.util.concurrent.CompletableFuture; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; +import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; /** @@ -311,8 +308,8 @@ public class RedisConnection implements RedisCommands { } } - public CompletableFuture forceFastReconnectAsync() { - CompletableFuture promise = new CompletableFuture(); + public CompletionStage forceFastReconnectAsync() { + CompletableFuture promise = new CompletableFuture<>(); fastReconnect = promise; closeInternal(); return promise;