diff --git a/src/contrib/cluster/Akka.DistributedData/DeltaPropagationSelector.cs b/src/contrib/cluster/Akka.DistributedData/DeltaPropagationSelector.cs index 9a81c111d56..8095161be97 100644 --- a/src/contrib/cluster/Akka.DistributedData/DeltaPropagationSelector.cs +++ b/src/contrib/cluster/Akka.DistributedData/DeltaPropagationSelector.cs @@ -70,9 +70,7 @@ public ImmutableDictionary
CollectPropagations() else { var i = (int)(_deltaNodeRoundRobinCounter % all.Length); - var endIndex = i + sliceSize; - if (endIndex > all.Length) endIndex = all.Length; - slice = all[i..endIndex]; + slice = all.Slice(i, sliceSize).ToImmutableArray(); if (slice.Length != sliceSize) slice = slice.AddRange(all.Take(sliceSize - slice.Length));