在上一篇文章中，我实现了Go BufferChan。但BufferChan作为一个独立库，实际使用上并不方便，所以想着把BufferChan整合进GoStream中。 原理是，将上一篇文章的实现原理封闭在在GoStream的BufferChan()中。

channel 是一种消息通信方式，常用于异步通信。 在通信过程中，将多个消息按一定数量或时间间隔缓存起来再批量发送，是一种常见的优化方式。常见的策略是，当消息数达到size或超时timeout未收到消息时触发一次消息。 Go实现如下。

这是一个之前分享过的Slides。

编写能跑的程序，是编程的最低要求，软件工程的真正难点在于架构和测试。大多数人对测试存在误解。

TL;DRGoStream是个参考Java StreamAPI，基于go-linq实现的数据处理库。它可以声明式地对数据进行转换、过滤、排序、分组、收集，而无需关心操作细节。

最近工作中想基于Event Sourcing重新设计计费系统。团队主要采用Go技术栈，而Go生态不成熟，缺少成熟CQRS框架实现，所以想着自己动手写个。参考Axon，整体设计如下。

《荷兰牧场和父老乡亲》是我最喜欢的一篇王小波杂文。