aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java')
-rw-r--r--messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java5
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() {