Skip to content

Commit

Permalink
Merge branch 'dev' into wip-persistence
Browse files Browse the repository at this point in the history
  • Loading branch information
Aaronontheweb committed Jun 22, 2018
2 parents 79484cd + 8463034 commit 334d899
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions src/core/Akka.Remote/RemoteWatcher.cs
Original file line number Diff line number Diff line change
Expand Up @@ -642,10 +642,13 @@ private void ProcessTerminated(IInternalActorRef watchee, bool existenceConfirme

if (!addressTerminated)
{
foreach (var watcher in Watching[watchee])
if (Watching.TryGetValue(watchee, out var watchers))
{
// ReSharper disable once ConditionIsAlwaysTrueOrFalse
watcher.SendSystemMessage(new DeathWatchNotification(watchee, existenceConfirmed, addressTerminated));
foreach (var watcher in watchers)
{
// ReSharper disable once ConditionIsAlwaysTrueOrFalse
watcher.SendSystemMessage(new DeathWatchNotification(watchee, existenceConfirmed, addressTerminated));
}
}
}

Expand Down

0 comments on commit 334d899

Please sign in to comment.