RxSwift<2>—— 核心逻辑源码分析

书接上文，RxSwif是所以优秀，其API十分精简

• 1.创建序列
• 2.订阅序列
• 3.发送信号

 //1.创建序列
        _ = Observable<String>.create { (obserber) -> Disposable in
            //3.发送信号
            obserber.onNext("我发送了数据信号")
            return Disposables.create()
            //2.订阅徐柳
        }.subscribe(onNext:{(text) in
            print("订阅到\(text)")
        })

分析代码：

• 1：创建序列的代码 Create 后面的 闭包A 里面有 3：发送信号，如果要执行 发送信号 ，必然要来到这个闭包A
• 2：我们执行 2: 订阅序列 创建了 闭包B
• 3：通过结果我们显然知道，先执行 闭包A 把 数据 传给了 闭包B

可观察序列的创建是利用协议拓展功能create实现的，里面创建了一个 AnonymousObservable（匿名可观察序列） 命名还是体现了作者的思维 ：这个类就是一个内部类，具备一些通用特性（具有自己功能的类才会命名） 下面我贴出这个类的继承关系

2.png

extension ObservableType {
    // MARK: create
    public static func create(_ subscribe: @escaping (AnyObserver<E>) -> Disposable) -> Observable<E> {
        return AnonymousObservable(subscribe)
    }
}

• 执行 create方法时候创建了一个内部对象AnonymousObservable
• AnonymousObservable 保存了外界闭包
• AnonymousObservable 继承了producer 具有subscribe

订阅序列

这里说明这个订阅方法 subscribe 和我们上面所说的 subscribe 不是同一个方法

来自于对 ObservableType 的拓展功能

extension ObservableType {
    public func subscribe(onNext: ((E) -> Void)? = nil, ...) -> Disposable {
           // 因为篇幅 省略不影响我们探索的代码
            let observer = AnonymousObserver<E> { event in                
                switch event {
                case .next(let value):
                    onNext?(value)
                case .error(let error):
                    if let onError = onError {
                        onError(error)
                    }
                    else {
                        Hooks.defaultErrorHandler(callStack, error)
                    }
                    disposable.dispose()
                case .completed:
                    onCompleted?()
                    disposable.dispose()
                }
            }
            return Disposables.create(
                self.asObservable().subscribe(observer),
                disposable
            )
    }
}

- self.asObservable() 这个是我们的 RxSwift 为了保持一致性的写法
- self.asObservable().subscribe(observer)其实本质就是 self.subscribe(observer),通过可观察序列的继承关系，我们可以非常快速的定位 Producer 订阅代码

1.png

总结：RxSwift的结构

- 1：就是序列感念，满世界都是序列 - 编码统一 ，随时随地享用
- 2：通过函数式思想吧一些列的需求操作下沉（把开发者不关心的东西封装），优化代码，节省逻辑
- 3：RxSwift最典型的特色就是解决Swift这门静态语言的响应能力，利用随时间维度序列变化为轴线，用户订阅关心能随轴线一直保活，达到订阅一次，响应一直持续