**Fix**:

- Fixed the issues of *ObservableDictionary* when subscribing/unsubscribing to actions while removing/adding elements
- Fixed the issues of *ObservableList* when subscribing/unsubscribing to actions while removing/adding elements

Author: CoderGamester

CHANGELOG.md

@@ -4,6 +4,12 @@ All notable changes to this package will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## [0.6.5] - 2024-11-20
+
+**Fix**:
+- Fixed the issues of *ObservableDictionary* when subscribing/unsubscribing to actions while removing/adding elements
+- Fixed the issues of *ObservableList* when subscribing/unsubscribing to actions while removing/adding elements
+
 ## [0.6.4] - 2024-11-13
 
 **Fix**:

Runtime/ObservableDictionary.cs

@@ -2,6 +2,7 @@
 using System.Collections;
 using System.Collections.Generic;
 using System.Collections.ObjectModel;
+using System.Linq;
 using UnityEngine.UIElements;
 
 // ReSharper disable once CheckNamespace
@@ -275,16 +276,18 @@ public virtual bool Remove(TKey key)
 
 			if (ObservableUpdateFlag != ObservableUpdateFlag.UpdateOnly && _keyUpdateActions.TryGetValue(key, out var actions))
 			{
-				for (var i = 0; i < actions.Count; i++)
+				var listCopy = actions.ToList();
+				for (var i = 0; i < listCopy.Count; i++)
 				{
-					actions[i](key, value, default, ObservableUpdateType.Removed);
+					listCopy[i](key, value, default, ObservableUpdateType.Removed);
 				}
 			}
 			if (ObservableUpdateFlag != ObservableUpdateFlag.KeyUpdateOnly)
 			{
-				for (var i = 0; i < _updateActions.Count; i++)
+				var listCopy = _updateActions.ToList();
+				for (var i = 0; i < listCopy.Count; i++)
 				{
-					_updateActions[i](key, value, default, ObservableUpdateType.Removed);
+					listCopy[i](key, value, default, ObservableUpdateType.Removed);
 				}
 			}
 
@@ -294,31 +297,34 @@ public virtual bool Remove(TKey key)
 		/// <inheritdoc />
 		public virtual void Clear()
 		{
-			var dictionary = new Dictionary<TKey, TValue>(Dictionary);
-
-			Dictionary.Clear();
-
 			if (ObservableUpdateFlag != ObservableUpdateFlag.UpdateOnly)
 			{
-				foreach (var data in _keyUpdateActions)
+				// Create a copy in case that one of the callbacks modifies the list (Ex: removing a subscriber)
+				var copy = new Dictionary<TKey, IList<Action<TKey, TValue, TValue, ObservableUpdateType>>>(_keyUpdateActions);
+
+				foreach (var data in copy)
 				{
-					for (var i = 0; i < data.Value.Count; i++)
+					var listCopy = data.Value.ToList();
+					for (var i = 0; i < listCopy.Count; i++)
 					{
-						data.Value[i](data.Key, dictionary[data.Key], default, ObservableUpdateType.Removed);
+						listCopy[i](data.Key, Dictionary[data.Key], default, ObservableUpdateType.Removed);
 					}
 				}
 			}
 
 			if (ObservableUpdateFlag != ObservableUpdateFlag.KeyUpdateOnly)
 			{
-				foreach (var data in dictionary)
+				foreach (var data in Dictionary)
 				{
-					for (var i = 0; i < _updateActions.Count; i++)
+					var listCopy = _updateActions.ToList();
+					for (var i = 0; i < listCopy.Count; i++)
 					{
-						_updateActions[i](data.Key, data.Value, default, ObservableUpdateType.Removed);
+						listCopy[i](data.Key, data.Value, default, ObservableUpdateType.Removed);
 					}
 				}
 			}
+
+			Dictionary.Clear();
 		}
 
 		/// <inheritdoc />
@@ -371,6 +377,7 @@ public void StopObserving(Action<TKey, TValue, TValue, ObservableUpdateType> onU
 					if (actions.Value[i] == onUpdate)
 					{
 						actions.Value.RemoveAt(i);
+						break;
 					}
 				}
 			}
@@ -380,6 +387,7 @@ public void StopObserving(Action<TKey, TValue, TValue, ObservableUpdateType> onU
 				if (_updateActions[i] == onUpdate)
 				{
 					_updateActions.RemoveAt(i);
+					break;
 				}
 			}
 		}

Runtime/ObservableList.cs

@@ -241,17 +241,18 @@ public virtual void RemoveAt(int index)
 		/// <inheritdoc />
 		public virtual void Clear()
 		{
-			var list = new List<T>(List);
+			// Create a copy in case that one of the callbacks modifies the list (Ex: removing a subscriber)
+			var copy = _updateActions.ToList();
 
-			List.Clear();
-
-			for (var i = 0; i < _updateActions.Count; i++)
+			for (var i = copy.Count - 1; i > -1; i--)
 			{
-				for (var j = 0; j < list.Count; j++)
+				for (var j = 0; j < List.Count; j++)
 				{
-					_updateActions[i](j, list[j], default, ObservableUpdateType.Removed);
+					copy[i](j, List[j], default, ObservableUpdateType.Removed);
 				}
 			}
+
+			List.Clear();
 		}
 
 		/// <inheritdoc />

Tests/Editor/ObservableListTest.cs

@@ -125,6 +125,21 @@ public void StopObserveCheck()
 			_caller.DidNotReceive().Call(Arg.Any<int>(), Arg.Any<int>(), Arg.Any<int>(), Arg.Any<ObservableUpdateType>());
 		}
 
+		[Test]
+		public void StopObserve_MultipleCalls_StopsOnlyOne()
+		{
+			_list.Observe(_caller.Call);
+			_list.Observe(_caller.Call);
+			_list.StopObserving(_caller.Call);
+			_list.Add(_previousValue);
+
+			_list[_index] = _previousValue;
+
+			_list.RemoveAt(_index);
+
+			_caller.Received().Call(Arg.Any<int>(), Arg.Any<int>(), Arg.Any<int>(), Arg.Any<ObservableUpdateType>());
+		}
+
 		[Test]
 		public void StopObservingAllCheck()
 		{
@@ -137,7 +152,7 @@ public void StopObservingAllCheck()
 		}
 
 		[Test]
-		public void StopObservingAll_MultipleCalls_Check()
+		public void StopObservingAll_MultipleCalls_StopsAll()
 		{
 			_list.Observe(_caller.Call);
 			_list.Observe(_caller.Call);

package.json

@@ -2,7 +2,7 @@
   "name": "com.gamelovers.dataextensions",
   "displayName": "Unity Data Type Extensions",
   "author": "Miguel Tomas",
-  "version": "0.6.4",
+  "version": "0.6.5",
   "unity": "2022.3",
   "license": "MIT",
   "description": "This package extends various sets of data types to be used in any type of data containers or persistent serializable data",