diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-18 07:13:53 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-18 07:13:53 +0100 |
commit | 592674c7317fd1e97107ed700fb7a039ef9365a7 (patch) | |
tree | 20a129c1f77a137c5c9d6cc2404ccc9b8743002d /messagebus | |
parent | 88a74a85691ee861f89669954a317781db000ab9 (diff) |
Just use Streams.toList as that is unmdifiable.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java index 8380c9d00ef..ee5c39f641b 100644 --- a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java @@ -17,7 +17,6 @@ import java.util.function.Consumer; import java.util.stream.Collectors; import java.util.stream.IntStream; -import static java.util.stream.Collectors.toUnmodifiableList; import static org.junit.jupiter.api.Assertions.assertTrue; /** @@ -307,7 +306,7 @@ public class DynamicThrottlePolicyTest { final int maximumTaskPerWorker; final int workerParallelism; final int[] currentTask; - final List<Deque<Consumer<Boolean>>> outstandingTasks; + final List<ArrayDeque<Consumer<Boolean>>> outstandingTasks; int pending = 0; MockServer(int workPerSuccess, int numberOfWorkers, int maximumTaskPerWorker, int workerParallelism) { @@ -318,7 +317,7 @@ public class DynamicThrottlePolicyTest { this.currentTask = new int[numberOfWorkers]; this.outstandingTasks = IntStream.range(0, numberOfWorkers) .mapToObj(__ -> new ArrayDeque<Consumer<Boolean>>()) - .collect(toUnmodifiableList()); + .toList(); } void tick() { |