null check

redis · Aug 15, 2024 · 2ae4fcc · 2ae4fcc
1 parent 7654fe2
commit 2ae4fcc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/io/lettuce/core/internal/AsyncConnectionProvider.java b/src/main/java/io/lettuce/core/internal/AsyncConnectionProvider.java
@@ -144,7 +144,9 @@ public CompletableFuture<Void> close() {
 
         for (K k : connections.keySet()) {
             Sync<K, T, F> remove = connections.remove(k);
-            remove.doWithConnection(e -> futures.add(e.closeAsync()));
+            if (remove != null) {
+                remove.doWithConnection(e -> futures.add(e.closeAsync()));
+            }
         }
 
         return Futures.allOf(futures);