如何理解ja8中stream的延迟作的意思？

为了简单起见，就不整泛型了，看着烦。

FilterStage和MapStage长啥样呢？

很简单对吧，Stage也没什么大不了的，<>就是把predicate和mapper包一下，不管内地的、的、的，纵然有这样或那样的不同，都是中国人对吧。用一个更大的抽象概念，去求同存异即可。

既然都是Stage，自然就可以用List<Stage>去<>一存储所有中间作。

重点看forEach：遍历每一个元素，为每个元素先执行中间作、再执行终端作，如果没有终端作，中间作不会启动（只是被存起来而已）。

至此，开头定义的第一、第二点都符合了。再来一把：

李健被filter了，所以没有后续作。元素也确实是逐个执行，并且仅遍历一次。

手写Stream版本4

为了稍微接近Ja8的StreamAPI，这里再迭代：优化forEach中的process。

process的逻辑是，对当前遍历到的元素，逐个执行所有中间作，内部用的是for循环。现在我要把它改成一种类似<>链式结构，你也可以叫它责任链，anyway。

怎么引入链式结构呢？这取决于你期望借助链式结构达到什么效果。

如，我期望最终的写法是这样的：

先别管Sink是什么，你可以把它看作另一种Stage，也是对中间作的封装。总之，通过wrapStages()，我们得到了一种链式结构，这条链上有我们通过filter()、map()等方法压入的中间作，<>只要调用sink.accept(element)，element就会沿着链条执行下去，就像往下水道倒了一碗水。

开始实施。

目前：stage负责<>封装中间作

目标

stage：组装链式结构sink：<>封装中间作、当前作执行结束后，<>将流程推向下一个

发现了吗，原本stage的职责转移给了sink，它有了新的职责：组装链式结构。

链式结构怎么来的

filter()、map()这些方法只负责存储predicate等作、不涉及组装，等到forEach触发后才会调用wrapStages()组装链式结构。

以filterStage为例：

也就是说，wrap干了两件事：

创建并返回新节点通过闭包，在新节点内部维持对旧节点的引用
forEachfilter->forEachmap->filter->forEach

链式作如何执行

调用forEach开启管道作：