RxSwift 源码解析(二)

RxSwift 源码解析(二)

RxSwift 订阅流程

/**
 * create: ObservableType.create
 *  -> AnonymousObservable._subscribeHandler
 *  -> 保存闭包
 *
 * subscribe
    -> AnonymousObserver: ObserverBase
    -> 保存闭包
 *
 * ObservableType.onNext
    -> AnyObservable.on
    -> AnonymousObservableSink.on
    -> sink.forwardOn
    -> ObservableBase.on
    -> AnonymousObserver.onCore
 */
    
let observable = Observable<String>.create { ob -> Disposable in
    ob.onNext("Rx Proxy")
    ob.onCompleted()
    return Disposables.create {
    }
}
    
_ = observable.subscribe(onNext: { str in
    print(str)
}, onError: { err in
    print("err")
}, onCompleted: {
    print("onCompleted")
}) {
    print("disposed")
}

创建 Observable

  • Create.swift里,Observable 创建AnonymousObserver类部类来实现保存创建的Event 闭包
  • AnonymousObserver: Producer
  • Producer: Observable
  • Observable: ObservableType

订阅 observable.subscribe

  • subscribe {} 里创建 AnonymousObserver 保存订阅的闭包
  • AnonymousObserver: ObserverBase
  • ObserverBase: ObservableType
  • 创建和订阅最终都是实现ObservableType协议来实现 Event 事件消息

发送消息 Event

  • ObservableType.onNext
  • -> AnyObservable.on
  • -> AnonymousObservableSink.on
  • -> sink.forwardOn
  • -> ObservableBase.on
  • -> AnonymousObserver.onCore

原理解析:通过实现上层协议,子类实现,逻辑下沉最终实现创建、订阅、发送序列。

Timer

RxSwift 里的 timer 底层是封装的 GCD 的 Timer, 不受 Runloop 的影响

Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        
Observable<Int>.timer(1, scheduler: MainScheduler.instance)

序列的创建

// 创建一个空序列
Observable<Any>.empty()


Observable.just([1,2,3])
Observable.from(arr)

// 创建序列的工厂方法
Observable<Int>.deferred { () -> Observable<Int> in
    if true {
        // todo 
    } else {
        // todo 
    }
}

// 类似于for 循环
Observable<Int>.generate(initialState: 0, condition: { $0 < 100 }, iterate: { $0 ++ })

// 创建单一元素的序列
Observable<Int>.repeatElement(1)

// error 事件
Observable<String>.error(NSError(domain: "error", code: 0, userInfo: nil))

//never 
Observable<Int>.never()

TextFiled 输入问题

  1. 直接赋值的时候subscribe不走
  • 去查文档,GitHub
_ = textFiled.rx.text.orEmpty
    .subscribe(onNext: { text in
        print(text)
    })
    
textFiled.text = "textfiled"
textFiled.sendActions(for: .allEditingEvents)

  1. subscribe订阅的时候会走两遍
  • 第一次是初始化的时候
  • 第二次是 edit begin 的时候
_ = textFiled.rx.text.orEmpty.skip(1)

防止多次订阅的时候多次相应 使用 share 来共享状态

.share(replay: 1, scope: .whileConnected)

DriverUI 使用的试试建议是用 Driver 序列

  • 一定在主线程
  • 避免多次订阅的多次发送
  • 一定不为空
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 开篇 一直觉得自己似乎越来越浮躁了,可能当代的大多数年轻人都活在恐慌里,问题已经从小时候的不思进取变成了“太思进取...
    Maru阅读 3,815评论 13 26
  • 最近在学习RxSwift相关的内容,在这里记录一些基本的知识点,以便今后查阅。 Observable 在RxSwi...
    L_Zephyr阅读 1,777评论 1 4
  • 当程序员原来越浮躁了,项目做多了大都是雷同的, 对技术没啥帮助,读一些牛逼的第三方框架,有助于提升,关于RxSwi...
    水落斜阳阅读 774评论 0 1
  • @TOC RxSwift序列核心逻辑 上一篇博客:Rxswift学习之(一)函数响应式编程思想只是简单的分析了序列...
    孔雨露阅读 685评论 2 6
  • 透视RxSwift核心逻辑 篇幅稍微有点长,了解程度不同,可以跳过某些部分。如果对源码比较熟悉的,建议直接看图就行...
    silasjs阅读 1,386评论 2 21