RxGo 是 Go 语言的 Reactive 扩展。
安装
用法
以上将：
将切片中每个数字的格式字符串 print 为4。
print 错误“bang”
重要的是要记住，只有一个 OnError 或 OnDone 可以在 stream 中调用。 如果 stream 中有错误，处理停止，OnDone 将永远不会被调用，反之亦然。
概念是将所有“side effects”分组到这些处理程序中，让一个 Observer 或任何 EventHandler 处理它们。
- 授权协议：
- MIT
- 开发语言：
- Google Go 查看源码»
- 操作系统：
- 跨平台
Go 语言的 Reactive 扩展 RxGo
