diff --git a/core-java/src/test/java/com/baeldung/java8/Java8FindAnyFindFirstTest.java b/core-java/src/test/java/com/baeldung/java8/Java8FindAnyFindFirstTest.java index c90b7d79c2..6a2b89963c 100644 --- a/core-java/src/test/java/com/baeldung/java8/Java8FindAnyFindFirstTest.java +++ b/core-java/src/test/java/com/baeldung/java8/Java8FindAnyFindFirstTest.java @@ -17,7 +17,7 @@ public class Java8FindAnyFindFirstTest { @Test public void createStream_whenFindAnyResultIsPresent_thenCorrect() { - List list = Arrays.asList("A","B","C","D"); + List list = Arrays.asList("A", "B", "C", "D"); Optional result = list.stream().findAny(); @@ -25,14 +25,27 @@ public class Java8FindAnyFindFirstTest { assertThat(result.get(), anyOf(is("A"), is("B"), is("C"), is("D"))); } + @Test + public void createParallelStream_whenFindAnyResultIsPresent_thenCorrect() throws Exception { + List list = Arrays.asList(1, 2, 3, 4, 5); + Optional result = list + .stream() + .parallel() + .filter(num -> num < 4) + .findAny(); + + assertTrue(result.isPresent()); + assertThat(result.get(), anyOf(is(1), is(2), is(3))); + } + @Test public void createStream_whenFindFirstResultIsPresent_thenCorrect() { - List list = Arrays.asList("A","B","C","D"); + List list = Arrays.asList("A", "B", "C", "D"); Optional result = list.stream().findFirst(); assertTrue(result.isPresent()); - assertThat(result.get(),is("A")); + assertThat(result.get(), is("A")); } }