fix(core): fix NPE on ImmutableStateChangeList when no changes (#461)

fix: #461
streamthoughts · Jun 4, 2024 · 563e256 · 563e256
1 parent 0c57f6b
commit 563e256
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/core/src/main/java/io/streamthoughts/jikkou/core/models/change/ImmutableStateChangeList.java b/core/src/main/java/io/streamthoughts/jikkou/core/models/change/ImmutableStateChangeList.java
@@ -43,12 +43,16 @@ public final class ImmutableStateChangeList<T extends StateChange> implements It
      */
     ImmutableStateChangeList(final List<T> values) {
         Map<String, List<T>> all = new LinkedHashMap<>();
-        values.forEach(data -> {
-            if (data != null) {
-                all.computeIfAbsent(data.getName(), unused -> new LinkedList<>()).add(data);
-            }
-        });
-        this.changes = Collections.unmodifiableList(values);
+        if (values != null) {
+            values.forEach(data -> {
+                if (data != null) {
+                    all.computeIfAbsent(data.getName(), unused -> new LinkedList<>()).add(data);
+                }
+            });
+            this.changes = Collections.unmodifiableList(values);
+        } else {
+            this.changes = Collections.emptyList();
+        }
         this.changesByName = Collections.unmodifiableMap(all);
     }