T
- 流元素的类型
S
-的实现流的类型
BaseStream
public interface BaseStream<T,S extends BaseStream<T,S>> extends AutoCloseable
Stream
和IntStream
的汇总操作 ,计算红色小部件的权重之和:
int sum = widgets.stream() .filter(w -> w.getColor() == RED) .mapToInt(w -> w.getWeight()) .sum();
请参阅类文档Stream
和封装文件java.util.stream对于流额外规范,流操作,流管道,以及并行性,支配所有流类型的行为。
Stream
, IntStream
, LongStream
, DoubleStream
, java.util.stream
Modifier and Type | Method and Description |
---|---|
void |
close()
关闭此流,导致此流管道的所有关闭处理程序被调用。
|
boolean |
isParallel()
返回此流是否要执行终端操作,将并行执行。
|
Iterator<T> |
iterator()
返回此流的元素的迭代器。
|
S |
onClose(Runnable closeHandler)
返回带有附加关闭处理程序的等效流。
|
S |
parallel()
返回平行的等效流。
|
S |
sequential()
返回顺序的等效流。
|
Spliterator<T> |
spliterator()
返回此流的元素的拼接器。
|
S |
unordered()
返回等效的流,即
unordered 。
|
Iterator<T> iterator()
这是一个terminal operation 。
Spliterator<T> spliterator()
这是一个terminal operation 。
boolean isParallel()
true
如果这个流如果被执行则并行执行
S sequential()
S parallel()
S unordered()
S onClose(Runnable closeHandler)
close()
方法时运行关闭处理程序,并按照添加的顺序执行。
所有关闭的处理程序都运行,即使较早的关闭处理程序抛出异常。
如果任何关闭处理程序抛出异常,则抛出的第一个异常将被中继到close()
的调用者, close()
将异常添加到该异常中作为禁止异常(除非其中一个异常与第一个异常相同,否则为第一个异常)异常不能压制自己。)可能返回自己。
这是一个intermediate operation 。
closeHandler
- 流关闭时执行的任务
void close()
close
在界面
AutoCloseable
AutoCloseable.close()