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")
}

創(chuàng)建 Observable

• 在 Create.swift里，Observable 創(chuàng)建AnonymousObserver類部類來(lái)實(shí)現(xiàn)保存創(chuàng)建的Event 閉包
• AnonymousObserver: Producer
• Producer: Observable
• Observable: ObservableType

訂閱 observable.subscribe

• 在 subscribe {} 里創(chuàng)建 AnonymousObserver 保存訂閱的閉包
• AnonymousObserver: ObserverBase
• ObserverBase: ObservableType
• 創(chuàng)建和訂閱最終都是實(shí)現(xiàn)ObservableType協(xié)議來(lái)實(shí)現(xiàn) Event 事件消息

發(fā)送消息 Event

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

原理解析：通過(guò)實(shí)現(xiàn)上層協(xié)議，子類實(shí)現(xiàn)，邏輯下沉最終實(shí)現(xiàn)創(chuàng)建、訂閱、發(fā)送序列。

Timer

RxSwift 里的 timer 底層是封裝的 GCD 的 Timer, 不受 Runloop 的影響

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

序列的創(chuàng)建

// 創(chuàng)建一個(gè)空序列
Observable<Any>.empty()


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

// 創(chuàng)建序列的工廠方法
Observable<Int>.deferred { () -> Observable<Int> in
    if true {
        // todo 
    } else {
        // todo 
    }
}

// 類似于for 循環(huán)
Observable<Int>.generate(initialState: 0, condition: { $0 < 100 }, iterate: { $0 ++ })

// 創(chuàng)建單一元素的序列
Observable<Int>.repeatElement(1)

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

//never 
Observable<Int>.never()

TextFiled 輸入問(wèn)題

1. 直接賦值的時(shí)候subscribe不走

• 去查文檔，GitHub

_ = textFiled.rx.text.orEmpty
    .subscribe(onNext: { text in
        print(text)
    })
    
textFiled.text = "textfiled"
textFiled.sendActions(for: .allEditingEvents)

2. subscribe訂閱的時(shí)候會(huì)走兩遍

• 第一次是初始化的時(shí)候
• 第二次是 edit begin 的時(shí)候

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

防止多次訂閱的時(shí)候多次相應(yīng) 使用 share 來(lái)共享狀態(tài)

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

Driver 和 UI 使用的試試建議是用 Driver 序列

• 一定在主線程
• 避免多次訂閱的多次發(fā)送
• 一定不為空