From 348b9cfa5e940f0aada723fd8d0e210c837ccbbb Mon Sep 17 00:00:00 2001 From: Grzegorz Piwowarek Date: Wed, 7 Feb 2024 18:06:50 +0100 Subject: [PATCH] Fix --- .../parallel_collectors/ParallelCollectorsUnitTest.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/libraries-stream/src/test/java/com/baeldung/parallel_collectors/ParallelCollectorsUnitTest.java b/libraries-stream/src/test/java/com/baeldung/parallel_collectors/ParallelCollectorsUnitTest.java index 582248b9be..d9dec3e278 100644 --- a/libraries-stream/src/test/java/com/baeldung/parallel_collectors/ParallelCollectorsUnitTest.java +++ b/libraries-stream/src/test/java/com/baeldung/parallel_collectors/ParallelCollectorsUnitTest.java @@ -37,16 +37,15 @@ public class ParallelCollectorsUnitTest { } @Test - public void shouldProcessInParallelWithParallelCollectors() { + public void shouldCollectInParallel() { ExecutorService executor = Executors.newFixedThreadPool(10); List ids = Arrays.asList(1, 2, 3); - CompletableFuture results = ids.stream() - .collect(parallel(ParallelCollectorsUnitTest::fetchById, executor, 4)) - .thenApply(s -> s.reduce("", (s1, s2) -> s1 + s2)); + CompletableFuture> results = ids.stream() + .collect(parallel(ParallelCollectorsUnitTest::fetchById, executor, 4)); - assertThat(results.join()).contains("user-1user-2user-3"); + assertThat(results.join()).containsExactly("user-1", "user-2", "user-3"); } @Test