aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-18 06:29:02 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-01-18 06:40:22 +0100
commit88a74a85691ee861f89669954a317781db000ab9 (patch)
tree0beac37eb81842309bc675fb0cdfb8cbb4074940 /messagebus
parent16ea68abd238c91016df203d37047e5dd3037144 (diff)
Unify on Streams.toList()
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java7
1 files changed, 4 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 8414f6588ea..8380c9d00ef 100644
--- a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
+++ b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
@@ -7,15 +7,16 @@ import com.yahoo.messagebus.test.SimpleReply;
import org.junit.jupiter.api.Test;
import java.util.ArrayDeque;
+import java.util.ArrayList;
import java.util.Collections;
import java.util.Deque;
import java.util.List;
import java.util.Random;
import java.util.concurrent.atomic.AtomicLong;
import java.util.function.Consumer;
+import java.util.stream.Collectors;
import java.util.stream.IntStream;
-import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toUnmodifiableList;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -218,7 +219,7 @@ public class DynamicThrottlePolicyTest {
System.err.printf("\n### Running %d operations of %d ticks each against %d workers with parallelism %d and queue size %d\n",
operations, workPerSuccess, numberOfWorkers, workerParallelism, maximumTasksPerWorker);
- List<Integer> order = IntStream.range(0, policies.length).boxed().collect(toList());
+ List<Integer> order = IntStream.range(0, policies.length).boxed().collect(Collectors.toCollection(ArrayList::new));
MockServer resource = new MockServer(workPerSuccess, numberOfWorkers, maximumTasksPerWorker, workerParallelism);
AtomicLong outstanding = new AtomicLong(operations);
AtomicLong errors = new AtomicLong(0);
@@ -350,4 +351,4 @@ public class DynamicThrottlePolicyTest {
}
-} \ No newline at end of file
+}