summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-18 07:13:53 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-01-18 07:13:53 +0100
commit592674c7317fd1e97107ed700fb7a039ef9365a7 (patch)
tree20a129c1f77a137c5c9d6cc2404ccc9b8743002d /messagebus
parent88a74a85691ee861f89669954a317781db000ab9 (diff)
Just use Streams.toList as that is unmdifiable.
Diffstat (limited to 'messagebus')
-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() {