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)

2. subscribe订阅的时候会走两遍

• 第一次是初始化的时候
• 第二次是 edit begin 的时候

_ = textFiled.rx.text.orEmpty.skip(1)

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

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

Driver 和 UI 使用的试试建议是用 Driver 序列

• 一定在主线程
• 避免多次订阅的多次发送
• 一定不为空