> 历史文化
swift的逻辑结构(swift原理)
导语:swift核心逻辑源码分析
RxSwift核心流程
RxSwift这个优秀的框架,设计的api也是非常精简,让陌生的用户也能非常快速上手
1: 创建序列2: 订阅序列3:发送信号我刚开始在探索的时候,我是比较好奇的:为什么我们的Cooci - 框架班级这个字符串会在订阅序列的subscribe的闭包打印。下面是我的代码分析
分析代码:
1:创建序列的代码 Create 后面的 闭包A 里面有 3:发送信号,如果要执行 发送信号 ,必然要来到这个闭包A2:我们执行 2: 订阅序列 创建了 闭包B3:通过结果我们显然知道,先执行 闭包A 把 Cooci - 框架班级 传给了 闭包B猜测:代码里面嵌套了闭包的执行调用!猜测的真实性,我们开始解读源码来验证RxSwift核心逻辑
创建序列
大家可以很清晰看到我们的 可观察序列 的创建是利用协议拓展功能的create方法实现的,里面创建了一个 AnonymousObservable(匿名可观察序列) 命名还是体现了作者的思维 :这个类就是一个内部类,具备一些通用特性(具有自己功能的类才会命名) 下面我贴出这个类的继承关系
从上面的图,我们可以清晰的看到的继承关系。那么这么多的内容还有那么多层嵌套,这个地方我们需要掌握什么:
create 方法的时候创建了一个内部对象 AnonymousObservableAnonymousObservable 保存了外界的闭包AnonymousObservable继承了 Producer 具有非常重要的方法 subscribe订阅序列
这里说明这个订阅方法 subscribe 和我们上面所说的 subscribe 不是同一个方法
来自于对 ObservableType 的拓展功能
代码说明:
E 这里的意思是 Swift 的关联类型,这个如果仔细看过可观察序列的继承链源码应该不难得出:这个E 就是我们的 序列类型,我们这里就是String创建了一个 AnonymousObserver (匿名内部观察者) 手法和我们的 AnonymousObservable 差不多,它这里的初始化是闭包参数,保存了外界的 onNext, onError , onCompleted , onDisposed 的处理回调闭包的调用,下面我还是给大家贴出 观察者 的继承链关系,帮助大家理解self.asObservable() 这个是我们的 RxSwift 为了保持一致性的写法self.asObservable().subscribe(observer)其实本质就是 self.subscribe(observer),通过可观察序列的继承关系,我们可以非常快速的定位 Producer 订阅代码关于销毁代码和调度者代码这里不分析self.run 这个代码最终由我们生产者 Producer 延伸到我们具体的事务代码 AnonymousObservable.runsink.run的写法也是比较好的,业务处理的还是下沉了,让分工更加明确parent 就是上面传过来的AnonymousObservable对象我们非常兴奋的看到 AnonymousObservable._subscribeHandler,从这句代码我们解惑了为什么我们的序列订阅的时候流程会执行我们 序列闭包,然后去执行 发送响应发送响应的代码等会分析,这里还有一个比较重要的家伙 AnyObserver(self)在这个构造方法里面,我们创建了一个结构体 AnyObserver 保存了一个信息 AnonymousObservableSink .on 函数,不是 AnonymousObservableSink,这个地方一般初次来到这里的人都会犯错误。不知道你是否意识到了!本文内容由小海整理编辑!