在Java 8中,我们有类Stream<T>,它奇怪地有一个方法

Iterator<T> iterator()

所以你会期望它实现接口Iterable<T>,这需要这个方法,但事实并非如此。

当我想使用foreach循环遍历一个流时,我必须做如下的事情

public static Iterable<T> getIterable(Stream<T> s) {
    return new Iterable<T> {
        @Override
        public Iterator<T> iterator() {
            return s.iterator();
        }
    };
}

for (T element : getIterable(s)) { ... }

我是不是遗漏了什么?


当前回答

如果你不介意使用第三方库,cyclops-react定义了一个Stream,它实现了Stream和Iterable,并且也是可重玩的(解决了kennytm所描述的问题)。

 Stream<String> stream = ReactiveSeq.of("hello","world")
                                    .map(s->"prefix-"+s);

或:-

 Iterable<String> stream = ReactiveSeq.of("hello","world")
                                      .map(s->"prefix-"+s);

 stream.forEach(System.out::println);
 stream.forEach(System.out::println);

[披露我是cyclops-react的主要开发者]

其他回答

我想指出的是,StreamEx确实实现了Iterable(和Stream),以及Stream中缺少的许多其他非常棒的功能。

如果你不介意使用第三方库,cyclops-react定义了一个Stream,它实现了Stream和Iterable,并且也是可重玩的(解决了kennytm所描述的问题)。

 Stream<String> stream = ReactiveSeq.of("hello","world")
                                    .map(s->"prefix-"+s);

或:-

 Iterable<String> stream = ReactiveSeq.of("hello","world")
                                      .map(s->"prefix-"+s);

 stream.forEach(System.out::println);
 stream.forEach(System.out::println);

[披露我是cyclops-react的主要开发者]

你可以在for循环中使用一个流,如下所示:

Stream<T> stream = ...;

for (T x : (Iterable<T>) stream::iterator) {
    ...
}

(在这里运行这个片段)

(这使用了Java 8函数接口强制转换。)

(这在上面的一些评论中有涉及(例如Aleksandr Dubinsky),但我想把它拉出来,让它更明显。)

不完美,但可以:

iterable = stream.collect(Collectors.toList());

并不完美,因为它将从流中获取所有项并将其放入List中,这并不是Iterable和stream的确切含义。他们应该是懒惰的。

要将流转换为可迭代对象,可以这样做

Stream<X> stream = null;
Iterable<X> iterable = stream::iterator

要将一个Stream传递给一个需要Iterable的方法,

void foo(Iterable<X> iterable)

简单的

foo(stream::iterator) 

然而,这可能看起来很有趣;说得更清楚一点可能会更好

foo( (Iterable<X>)stream::iterator );