diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-18 06:29:02 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-18 06:40:22 +0100 |
commit | 88a74a85691ee861f89669954a317781db000ab9 (patch) | |
tree | 0beac37eb81842309bc675fb0cdfb8cbb4074940 /messagebus | |
parent | 16ea68abd238c91016df203d37047e5dd3037144 (diff) |
Unify on Streams.toList()
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java | 7 |
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 +} |