Merge branch 'feature/notifications' into dev

2026-01-27 11:24:35 +01:00
parent 752a487cb0 6cab16b5bb
commit 2088cd608d
1 changed files with 3 additions and 1 deletions
--- a/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageBus.java
+++ b/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageBus.java
@@ -3,6 +3,8 @@ package de.srsoftware.umbrella.messagebus;

 import de.srsoftware.umbrella.messagebus.events.Event;
 import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
 import java.util.Set;

 public class MessageBus {
@@ -15,7 +17,7 @@ public class MessageBus {
 		new Thread(() -> { // TODO: use thread pool
 			try {
 				Thread.sleep(100);
-				listeners.parallelStream().forEach(l -> l.onEvent(event));
+				List.copyOf(listeners).parallelStream().forEach(l -> l.onEvent(event));
 			} catch (InterruptedException ignored) {
 			}
 		}).start();