我有一个返回java.lang.Iterable<T>的接口。
我想使用Java 8流API来操作这个结果。
然而Iterable不能“流”。
任何想法如何使用Iterable作为流而不转换为列表?
我有一个返回java.lang.Iterable<T>的接口。
我想使用Java 8流API来操作这个结果。
然而Iterable不能“流”。
任何想法如何使用Iterable作为流而不转换为列表?
当前回答
我想建议使用JOOL库,它隐藏了Seq.seq(iterable)调用背后的分割器魔法,还提供了一大堆额外的有用功能。
其他回答
解决这个问题的一个非常简单的方法是创建一个Streamable<T>接口,扩展Iterable<T>,其中包含一个默认的<T> stream()方法。
interface Streamable<T> extends Iterable<T> {
default Stream<T> stream() {
return StreamSupport.stream(spliterator(), false);
}
}
现在你的任何Iterable<T>都可以通过声明它们来实现streamable <T>而不是Iterable<T>。
我创建了这个类:
public class Streams {
/**
* Converts Iterable to stream
*/
public static <T> Stream<T> streamOf(final Iterable<T> iterable) {
return toStream(iterable, false);
}
/**
* Converts Iterable to parallel stream
*/
public static <T> Stream<T> parallelStreamOf(final Iterable<T> iterable) {
return toStream(iterable, true);
}
private static <T> Stream<T> toStream(final Iterable<T> iterable, final boolean isParallel) {
return StreamSupport.stream(iterable.spliterator(), isParallel);
}
}
我认为它是完全可读的,因为您不必考虑分裂器和布尔值(isParallel)。
我想建议使用JOOL库,它隐藏了Seq.seq(iterable)调用背后的分割器魔法,还提供了一大堆额外的有用功能。
所以另一个回答提到,Guava支持使用:
Streams.stream(iterable);
我想强调的是,该实现与其他答案略有不同。如果Iterable类型为Collection,则对其进行强制转换。
public static <T> Stream<T> stream(Iterable<T> iterable) {
return (iterable instanceof Collection)
? ((Collection<T>) iterable).stream()
: StreamSupport.stream(iterable.spliterator(), false);
}
public static <T> Stream<T> stream(Iterator<T> iterator) {
return StreamSupport.stream(
Spliterators.spliteratorUnknownSize(iterator, 0),
false
);
}
如果你碰巧使用Vavr(以前称为Javaslang),这可以很简单:
Iterable i = //...
Stream.ofAll(i);