From e52b815d0b992ffa35229ab58663d7663fb058a6 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 22 Jan 2025 16:49:22 -0600 Subject: [PATCH] =?UTF-8?q?Revert=20"DData:=20Fix=20BCL=20update=20causing?= =?UTF-8?q?=20DeltaPropagationSelector=20throwing=20Index=E2=80=A6"=20(#74?= =?UTF-8?q?83)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit 5c7c967c4ba8cb8c397a60a93f6a7c7b70c79c48. --- .../cluster/Akka.DistributedData/DeltaPropagationSelector.cs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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));