Use Stream.builder instead of ArrayList (#467)

pivovarit · Mar 19, 2020 · c1f3d36 · c1f3d36
1 parent 7a89f40
commit c1f3d36
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java b/src/main/java/com/pivovarit/collectors/AsyncParallelCollector.java
@@ -136,11 +136,11 @@ static void requireValidParallelism(int parallelism) {
 
     static <T, R, RR> Collector<T, ?, CompletableFuture<RR>> asyncCollector(Function<T, R> mapper, Executor executor, Function<Stream<R>, RR> finisher) {
         return collectingAndThen(toList(), list -> supplyAsync(() -> {
-            List<R> acc = new ArrayList<>(list.size());
+            Stream.Builder<R> acc = Stream.builder();
             for (T t : list) {
                 acc.add(mapper.apply(t));
             }
-            return finisher.apply(acc.stream());
+            return finisher.apply(acc.build());
         }, executor));
     }