ObserverType ObserverType,观察者核心函数func on(_ event: Event<E>)，观察者一旦观察到变化，立...

先来看看核心代码subscribe 其实看代码是有技巧的，我一看到这个代码我就知道这个if..else是跟线程安全有关的，如果你重点关注线程安全...

about sequence 先引用下官方文档： Here is a sequence of numbers: Another sequence...

先看下简单的例子：上面例子的订阅事件会被调度到主线程中去，那么具体是怎么调度，以及细节是什么样的呢？ 轻车熟路的找到入口位置 这个schedul...

首先我们要分析下需求，哪些操作是需要保证线程安全的。 显然_state的设置是要保证线程安全的， 那么与之相关的读写操作都是要加锁的，因此 is...

前言 这里的分类指的是按照实现原理分类，而不是按照功能进行分类，针对每一个分类选择一个具体类型，进行分析 Override subscribe ...

PublishSubject继承类和协议 Observable: 被观察者 Cancelable: 可以被dispose Synchronize...

使用示例 Applies a transforming closure to elements emitted by an Observable...

使用示例 类型推断 我们可能会写这种 但是 又是个什么鬼？ 分析下of的函数原型 可以看到对范型E,没有做任何约束，所以Observable.o...