如何将Java枚举转换为流？

Question

我有一个第三方库，它给我一个枚举 。我希望将该枚举作为Java8stream来使用，在其上调用诸如filter、map和flatmap之类的东西。

是否有一个现有的库中包含此内容？我已经引用了Guava和Apache Commons，所以如果其中任何一个都有理想的解决方案。

或者，将枚举转换为流同时保留所有内容的惰性的最佳/最简单的方法是什么？

Answer 1

此答案已经提供了一个解决方案，该解决方案通过枚举创建流:

 public static <T> Stream<T> enumerationAsStream(Enumeration<T> e) {
     return StreamSupport.stream(
         Spliterators.spliteratorUnknownSize(
             new Iterator<T>() {
                 public T next() {
                     return e.nextElement();
                 }
                 public boolean hasNext() {
                     return e.hasMoreElements();
                 }
             },
             Spliterator.ORDERED), false);
 }

需要强调的是，生成的流与任何其他流一样懒散，因为在终端操作开始之前，它不会处理任何项，并且如果终端操作短路，它将只迭代必要的项。

尽管如此，它仍有改进的空间。当有一种简单的方法来处理所有元素时，我总是会添加foreachlefting方法。对于大多数非短路操作，stream实现将调用所述方法：

public static <T> Stream<T> enumerationAsStream(Enumeration<T> e) {
    return StreamSupport.stream(
        Spliterators.spliteratorUnknownSize(
            new Iterator<T>() {
                public T next() {
                    return e.nextElement();
                }
                public boolean hasNext() {
                    return e.hasMoreElements();
                }
                public void forEachRemaining(Consumer<? super T> action) {
                    while(e.hasMoreElements()) action.accept(e.nextElement());
                }
            },
            Spliterator.ORDERED), false);
}

但是，上面的代码是“UsingIteratorbeause it is so farmony”反模式的牺牲品。创建的迭代器将包装到新的spliterator接口的实现中，与直接实现spliterator相比，它没有任何优势：

public static <T> Stream<T> enumerationAsStream(Enumeration<T> e) {
    return StreamSupport.stream(
        new Spliterators.AbstractSpliterator<T>(Long.MAX_VALUE, Spliterator.ORDERED) {
            public boolean tryAdvance(Consumer<? super T> action) {
                if(e.hasMoreElements()) {
                    action.accept(e.nextElement());
                    return true;
                }
                return false;
            }
            public void forEachRemaining(Consumer<? super T> action) {
                while(e.hasMoreElements()) action.accept(e.nextElement());
            }
    }, false);
}

在源代码级别上，此实现与基于迭代器的实现一样简单，但消除了从拆分器到迭代器的委派。它只要求它的读者了解新的API。