We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9721530 commit 4b4aa1dCopy full SHA for 4b4aa1d
scylla/src/policies/load_balancing/default.rs
@@ -2807,12 +2807,11 @@ mod latency_awareness {
2807
}
2808
2809
2810
- let mut fast_targets = fast_targets.into_iter();
2811
- let mut penalised_targets = penalised_targets.into_iter();
+ let fast_targets = fast_targets.into_iter();
+ let penalised_targets = penalised_targets.into_iter();
2812
2813
- let skipping_penalised_targets_iterator = std::iter::from_fn(move || {
2814
- fast_targets.next().or_else(|| penalised_targets.next())
2815
- });
+ let skipping_penalised_targets_iterator =
+ fast_targets.into_iter().chain(penalised_targets);
2816
2817
Either::Right(skipping_penalised_targets_iterator)
2818
0 commit comments