#325: Fuse toArray into Stream chain.

commercetools · Nov 24, 2018 · 325ed1d · 325ed1d
1 parent c275a52
commit 325ed1d
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/src/main/java/com/commercetools/sync/inventories/InventorySync.java b/src/main/java/com/commercetools/sync/inventories/InventorySync.java
@@ -98,13 +98,11 @@ protected CompletionStage<InventorySyncStatistics> process(@Nonnull final List<I
         final List<InventoryEntryDraft> validInventories = inventories.stream()
             .filter(this::validateDraft)
             .collect(toList());
-        final List<CompletableFuture<InventorySyncStatistics>> completableFutures = IntStream
-            .range(0, calculateNumberOfBatches(validInventories.size()))
-            .mapToObj(batchIndex -> getBatch(batchIndex, validInventories))
-            .map(this::processBatch)
-            .map(CompletionStage::toCompletableFuture)
-            .collect(toList());
-        return allOf(completableFutures.toArray(new CompletableFuture[completableFutures.size()]))
+        return allOf(IntStream
+                .range(0, calculateNumberOfBatches(validInventories.size()))
+                .mapToObj(batchIndex -> getBatch(batchIndex, validInventories))
+                .map(this::processBatch)
+                .map(CompletionStage::toCompletableFuture).toArray(CompletableFuture[]::new))
             .thenApply(v -> {
                 statistics.incrementProcessed(inventories.size());
                 return statistics;