goZero

https://mp.weixin.qq.com/s/tkm9nYcyUxE2vUbplSO-pA
go-zero是一个功能完备的微服务框架，框架中内置了很多非常实用的工具，其中就包含流数据处理工具fx
inputStream 函数模拟了流数据的产生，outputStream 函数模拟了流数据的处理过程，其中 From 函数为流的输入，Walk 函数并发的作用在每一个 item 上，Filter 函数对 item 进行过滤为 true 保留为 false 不保留，ForEach 函数遍历输出每一个 item 元素。

流数据处理中间操作
一个流的数据处理可能存在许多的中间操作，每个中间操作都可以作用在流上。就像流水线上的工人一样，每个工人操作完零件后都会返回处理完成的新零件，同理流处理中间操作完成后也会返回一个新的流。
https://gocn.vip/topics/11077

https://github.com/tal-tech/go-zero/tree/master/core/fx
https://gocn.vip/topics/10941
https://github.com/tal-tech/go-zero/blob/master/core/mr/mapreduce.go