This is an automated email from the ASF dual-hosted git repository. ggregory pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/commons-lang.git
commit 9be39c4a7aa7a9a0e3e9cbf29c85884623a9fa4f Author: Gary Gregory <garydgreg...@gmail.com> AuthorDate: Sat Jul 16 14:44:06 2022 -0400 Add Streams.of(Iterable<E>) --- src/changes/changes.xml | 1 + src/main/java/org/apache/commons/lang3/stream/Streams.java | 12 ++++++++++++ .../java/org/apache/commons/lang3/stream/StreamsTest.java | 11 +++++++++++ 3 files changed, 24 insertions(+) diff --git a/src/changes/changes.xml b/src/changes/changes.xml index e5e32ada0..f16b4ad6b 100644 --- a/src/changes/changes.xml +++ b/src/changes/changes.xml @@ -158,6 +158,7 @@ The <action> type attribute can be add,update,fix,remove. <action issue="LANG-1627" type="add" dev="ggregory" due-to="Alberto Scotto, Avijit Chakraborty, Steve Bosman, Bruno P. Kinoshita, Gary Gregory">Add ArrayUtils.oneHot().</action> <action issue="LANG-1662" type="add" dev="ggregory" due-to="Daniel Augusto Veronezi Salvador, Gary Gregory, Bruno P. Kinoshita">Let ReflectionToStringBuilder only reflect given field names #849.</action> <action type="add" dev="ggregory" due-to="Gary Gregory">Add Streams.of(Enumeration<E>).</action> + <action type="add" dev="ggregory" due-to="Gary Gregory">Add Streams.of(Iterable<E>).</action> <!-- UPDATE --> <action type="update" dev="ggregory" due-to="Dependabot, XenoAmess, Gary Gregory">Bump actions/cache from 2.1.4 to 3.0.5 #742, #752, #764, #833, #867.</action> <action type="update" dev="ggregory" due-to="Dependabot">Bump actions/checkout from 2 to 3 #819, #825, #859.</action> diff --git a/src/main/java/org/apache/commons/lang3/stream/Streams.java b/src/main/java/org/apache/commons/lang3/stream/Streams.java index eee85087e..ee576c723 100644 --- a/src/main/java/org/apache/commons/lang3/stream/Streams.java +++ b/src/main/java/org/apache/commons/lang3/stream/Streams.java @@ -641,6 +641,18 @@ public class Streams { return StreamSupport.stream(new EnumerationSpliterator<>(Long.MAX_VALUE, Spliterator.ORDERED, enumeration), false); } + /** + * Creates a stream on the given Iterable. + * + * @param <E> the type of elements in the Iterable. + * @param iterable the Iterable to stream or null. + * @return a new Stream or {@link Stream#empty()} if the Iterable is null. + * @since 3.13.0 + */ + public static <E> Stream<E> of(final Iterable<E> iterable) { + return iterable == null ? Stream.empty() : StreamSupport.stream(iterable.spliterator(), false); + } + /** * Null-safe version of {@link Stream#of(Object[])}. * diff --git a/src/test/java/org/apache/commons/lang3/stream/StreamsTest.java b/src/test/java/org/apache/commons/lang3/stream/StreamsTest.java index 3db2ec794..073e9cc71 100644 --- a/src/test/java/org/apache/commons/lang3/stream/StreamsTest.java +++ b/src/test/java/org/apache/commons/lang3/stream/StreamsTest.java @@ -188,6 +188,17 @@ public class StreamsTest extends AbstractLangTest { assertEquals(2, collect.size()); } + @Test + public void testOfIterableNotNull() { + assertEquals(2, Streams.of((Iterable<String>) Arrays.asList("A", "B")).collect(Collectors.toList()).size()); + } + + @Test + public void testOfIterableNull() { + final Iterable<String> input = null; + assertEquals(0, Streams.of(input).collect(Collectors.toList()).size()); + } + @Test public void testSimpleStreamFilter() { final List<String> input = Arrays.asList("1", "2", "3", "4", "5", "6");