文件名称：RxGo：Go语言的React性扩展
文件大小：182KB
文件格式：ZIP
更新时间：2024-03-17 11:54:44
golang reactivex stream observable observable-streams
RxGo Go语言的React式扩展 React性X 或简称Rx，是用于使用Observable流进行编程的API。 这是Go语言的官方ReactiveX API。 ReactiveX是一种新的异步编程方法，可以替代回调，promise和deferd。 它与处理事件或项目流有关，事件是系统中的任何发生或更改。 事件流称为 。 运算符是一个函数，它定义一个Observable，如何以及何时发出数据。 涵盖了运营商列表。 RxGo RxGo实现基于的概念。 管道是通过通道连接的一系列阶段，其中每个阶段是一组运行相同功能的goroutine。 让我们看一个具体的示例，每个框都是一个运算符： 我们使用Just运算符基于固定的项目列表创建静态Observable。 我们使用Map运算符定义一个转换函数（将一个圆转换为一个正方形）。 我们使用Filter运算符过滤每个黄色方块。 在