ObserverManager: fix Collection was modified

dotnet · Nov 4, 2023 · 905cf60 · 905cf60
1 parent 84a1678
commit 905cf60
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Orleans.Core/Utils/ObserverManager.cs b/src/Orleans.Core/Utils/ObserverManager.cs
@@ -153,7 +153,7 @@ public async Task Notify(Func<TObserver, Task> notification, Func<TObserver, boo
         {
             var now = GetDateTime();
             var defunct = default(List<TIdentity>);
-            foreach (var observer in _observers)
+            foreach (var observer in _observers.ToList())
             {
                 if (observer.Value.LastSeen + ExpirationDuration < now)
                 {
@@ -208,7 +208,7 @@ public void Notify(Action<TObserver> notification, Func<TObserver, bool> predica
         {
             var now = GetDateTime();
             var defunct = default(List<TIdentity>);
-            foreach (var observer in _observers)
+            foreach (var observer in _observers.ToList())
             {
                 if (observer.Value.LastSeen + ExpirationDuration < now)
                 {
@@ -257,7 +257,7 @@ public void ClearExpired()
         {
             var now = GetDateTime();
             var defunct = default(List<TIdentity>);
-            foreach (var observer in _observers)
+            foreach (var observer in _observers.ToList())
             {
                 if (observer.Value.LastSeen + ExpirationDuration < now)
                 {