code samples for issue BAEL-4877

2021-04-05 16:54:01 -03:00
parent 00482852bd
commit b37e11f2cb
3 changed files with 81 additions and 0 deletions
@@ -0,0 +1,30 @@
+package com.baeldung.streams.conversion;
+
+import java.util.Enumeration;
+import java.util.Spliterators.AbstractSpliterator;
+import java.util.function.Consumer;
+
+public class EnumerationSpliterator<T> extends AbstractSpliterator<T> {
+
+    private final Enumeration<T> enumeration;
+
+    public EnumerationSpliterator(long est, int additionalCharacteristics, Enumeration<T> enumeration) {
+        super(est, additionalCharacteristics);
+        this.enumeration = enumeration;
+    }
+
+    @Override
+    public boolean tryAdvance(Consumer<? super T> action) {
+        if (enumeration.hasMoreElements()) {
+            action.accept(enumeration.nextElement());
+            return true;
+        }
+        return false;
+    }
+
+    @Override
+    public void forEachRemaining(Consumer<? super T> action) {
+        while (enumeration.hasMoreElements())
+            action.accept(enumeration.nextElement());
+    }
+}
@@ -0,0 +1,16 @@
+package com.baeldung.streams.conversion;
+
+import java.util.Enumeration;
+import java.util.Spliterator;
+import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
+
+public class EnumerationStreamConversion {
+
+    public static <T> Stream<T> convert(Enumeration<T> enumeration) {
+        EnumerationSpliterator<T> spliterator = new EnumerationSpliterator<T>(Long.MAX_VALUE, Spliterator.ORDERED, enumeration);
+        Stream<T> stream = StreamSupport.stream(spliterator, false);
+
+        return stream;
+    }
+}