RxSwift 角色定位
- 观察者（Observer）
- 被观察者(可观察的)（Observable）
- 订阅者（Subscriber） 事件的最终处理者
- 管道（Sink） Observer 和 Observable 沟通的桥梁
Observable<String>.create { observer -> Disposable in
observer.onNext("hello")
return Disposables.create()
}
.subscribe { event in
print(event.element)
}
Observable(被观察者)继承链
-
Observable 继承关系图
观察类继承链
Observable 继承体系
-
Observable的核心函数
a. subscribe 订阅操作, Observable和 Observer 通过订阅建立联系,
Observable 好比水源， Observer 好比水龙头(永远开着的水龙头)， 订阅的过程就是在Observable 和 Observer 之间建立管道， 一旦建立管道即是永久性的，只要水源有谁， 水龙头就会有水;
b. run 对用户不可见，隐藏了大量的实现细节， 这个函数就是建立水管的过程;
c. asObservable： 这个协议的存在使得Observable 的定义变得更加广泛。
-
asObservable的函数实现：
public func asObservable() -> Observable<Element> {
return source
}
-ObservableType 协议扩展
extension ObservableType {
public func subscribe(_ on: @escaping (Event<E>) -> Void)
-> Disposable {
let observer = AnonymousObserver { e in
on(e)
}
return self.asObservable().subscribe(observer)
}
}
ObservableType:扩展 subscribe方法， 确保所有的Observable行为一致， 都是经由self.asObservable()获取Observable;
Observer 继承体系
Observer 继承体系
Observer 继承体系
订阅、序列流程
订阅调用方法流程图
