能否支持自定义中间操作

[nasodaengineer]

就像JEP 473: Stream Gatherers，看了Gather的接口，没想到怎么实现这样的效果：

source.gather(a).gather(b).gather(c).collect(...)
is equivalent to
source.gather(a.andThen(b).andThen(c)).collect(...)

[trumansdo]

就像JEP 473: Stream Gatherers，看了Gather的接口，没想到怎么实现这样的效果：

source.gather(a).gather(b).gather(c).collect(...)
is equivalent to
source.gather(a.andThen(b).andThen(c)).collect(...)

Gather与仓库中Reducer本质是一个东西，你可以用Reducer实现。从概念来说：stream中reduce/map无外乎就收集和转换两个动作，而且reduce中可以嵌套map，map中也可以嵌套reduce。你可以看那个window的实现呀。

[nasodaengineer]

就像JEP 473: Stream Gatherers，看了Gather的接口，没想到怎么实现这样的效果：

source.gather(a).gather(b).gather(c).collect(...)
is equivalent to
source.gather(a.andThen(b).andThen(c)).collect(...)

Gather与仓库中Reducer本质是一个东西，你可以用Reducer实现。从概念来说：stream中reduce/map无外乎就收集和转换两个动作，而且reduce中可以嵌套map，map中也可以嵌套reduce。你可以看那个window的实现呀。

有本质区别，你这个相当于Collector.toStream()，即便Java Stream也能做到自定义中间操作，但Seq的API中reduce就是个终结操作，即便你传的Reducer.toList()这是个惰性Seq，也会立即执行。window的实现没问题，但是要硬编码。在API的易用性上和Gatherer有很大差距，你能用Reducer实现 r1.andThen(r2).andThen(r3)，然后在丢给Seq.reduce()用么

[wolray]

看起来是个新东西，gather可以做局部聚合。
现在天天写Go，真怀念可以写Java的时光啊。

[nasodaengineer]

看起来是个新东西，gather可以做局部聚合。 现在天天写Go，真怀念可以写Java的时光啊。

java找不到工作咯，发个1.0.3呗，Async相关的