Add guards to catch null arguments in AsyncConnectionProvider.forEach…

…(…) #1301
redis · Jun 8, 2020 · a076b77 · a076b77
1 parent 4f9d330
commit a076b77
Showing 1 changed file with 8 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
@@ -187,7 +187,14 @@ public void close(K key) {
      * @param action the action.
      */
     public void forEach(Consumer<? super T> action) {
-        connections.values().forEach(sync -> sync.doWithConnection(action));
+
+        LettuceAssert.notNull(action, "Action must not be null!");
+
+        connections.values().forEach(sync -> {
+            if (sync != null) {
+                sync.doWithConnection(action);
+            }
+        });
     }
 
     /**