Make listeners of WaterRower thread-safe

tbressler · Feb 8, 2021 · 175c991 · 175c991
1 parent 5f6f298
commit 175c991
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/de/tbressler/waterrower/WaterRower.java b/src/main/java/de/tbressler/waterrower/WaterRower.java
@@ -25,6 +25,7 @@
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 import static de.tbressler.waterrower.io.msg.out.ConfigureWorkoutMessage.MessageType.*;
 import static de.tbressler.waterrower.model.ErrorCode.*;
@@ -57,7 +58,7 @@ public class WaterRower {
     private final DeviceVerificationWatchdog deviceVerificationWatchdog;
 
     /* All listeners. */
-    private List<IWaterRowerConnectionListener> listeners = new ArrayList<>();
+    private List<IWaterRowerConnectionListener> listeners = new CopyOnWriteArrayList<>();
 
 
     /* The listener for the WaterRower connector. */