diff --git a/src/core/Akka.Cluster/ClusterReadView.cs b/src/core/Akka.Cluster/ClusterReadView.cs index 7b0332fc62e..829366cb2f2 100644 --- a/src/core/Akka.Cluster/ClusterReadView.cs +++ b/src/core/Akka.Cluster/ClusterReadView.cs @@ -132,7 +132,7 @@ public EventBusListener(Cluster cluster, ClusterReadView readView) }) .With(changed => { - State = State.Copy(roleLeaderMap: State.RoleLeaderMap.Add(changed.Role, changed.Leader)); + State = State.Copy(roleLeaderMap: State.RoleLeaderMap.SetItem(changed.Role, changed.Leader)); }) .With(stats => {