RxSwift deferred

網上只有deferred的使用,鮮有其源碼流程播赁,因其十分簡潔,故詳細貼上步驟吼渡,如有誤行拢,請留言指出,謝謝

let obv_defer = Observable<Int>.deferred { () -> Observable<Int> in
            return Observable.just(1)
        }        
obv_defer.subscribe(onNext:{
            print($0)
            }).disposed(by: disposeBag)
貼出關鍵步驟:

deferred后返回return Deferred(observableFactory: observableFactory),保存了工廠閉包舟奠,subscribe了AnonymousObserver后竭缝,來到deferred的run方法

override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable)
             where Observer.Element == Source.Element {
        let sink = DeferredSink(observableFactory: self._observableFactory, observer: observer, cancel: cancel)
        let subscription = sink.run()
        return (sink: sink, subscription: subscription)
    }

生成一個繼承于Sink的DeferredSink,然后sink走run

func run() -> Disposable {
        do {
            let result = try self._observableFactory()
            return result.subscribe(self)
        }
        catch let e {
            self.forwardOn(.error(e))
            self.dispose()
            return Disposables.create()
        }
    }

這里是核心沼瘫,也就是工廠里生成新Observable的時機抬纸,執(zhí)行deferred保存的工廠閉包,拿到閉包返回的Observable耿戚,這里是Just(1)湿故,由工廠新生成的observable來subscribe自身,也就是deferredSink

override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
        observer.on(.next(self._element))
        observer.on(.completed)
        return Disposables.create()
    }

來到Just的subscribe方法膜蛔,on出next后坛猪,來到deferredSink的on方法

func on(_ event: Event<Element>) {
        self.forwardOn(event)
        
        switch event {
        case .next:
            break
        case .error:
            self.dispose()
        case .completed:
            self.dispose()
        }
    }

forwardOn來到父類Sink

final func forwardOn(_ event: Event<Observer.Element>) {
        #if DEBUG
            self._synchronizationTracker.register(synchronizationErrorMessage: .default)
            defer { self._synchronizationTracker.unregister() }
        #endif
        if isFlagSet(self._disposed, 1) {
            return
        }
        self._observer.on(event)
    }

self._observer就是之前的AnonymousObserver

override func onCore(_ event: Event<Element>) {
        return self._eventHandler(event)
    }

AnonymousObserver只保存了一個閉包,也只有一個onCore方法皂股,走到父類observerBase

func on(_ event: Event<Element>) {
        switch event {
        case .next:
            if load(self._isStopped) == 0 {
                self.onCore(event)
            }
        case .error, .completed:
            if fetchOr(self._isStopped, 1) == 0 {
                self.onCore(event)
            }
        }
    }

onCore后墅茉,調用AnonymousObserver的閉包,然后事件閉包onNext調用呜呐,走完最開始的print就斤。最后是方法一系列返回,走完Just發(fā)送的completed蘑辑,再一系列返回洋机,走完BinaryDisposable,走完dispose洋魂,結束绷旗。

最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市副砍,隨后出現(xiàn)的幾起案子刁标,更是在濱河造成了極大的恐慌,老刑警劉巖址晕,帶你破解...
    沈念sama閱讀 206,311評論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件膀懈,死亡現(xiàn)場離奇詭異,居然都是意外死亡谨垃,警方通過查閱死者的電腦和手機启搂,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,339評論 2 382
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來刘陶,“玉大人胳赌,你說我怎么就攤上這事〕赘簦” “怎么了疑苫?”我有些...
    開封第一講書人閱讀 152,671評論 0 342
  • 文/不壞的土叔 我叫張陵,是天一觀的道長。 經常有香客問我捍掺,道長撼短,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 55,252評論 1 279
  • 正文 為了忘掉前任挺勿,我火速辦了婚禮曲横,結果婚禮上,老公的妹妹穿的比我還像新娘不瓶。我一直安慰自己禾嫉,他們只是感情好,可當我...
    茶點故事閱讀 64,253評論 5 371
  • 文/花漫 我一把揭開白布蚊丐。 她就那樣靜靜地躺著熙参,像睡著了一般。 火紅的嫁衣襯著肌膚如雪麦备。 梳的紋絲不亂的頭發(fā)上孽椰,一...
    開封第一講書人閱讀 49,031評論 1 285
  • 那天,我揣著相機與錄音泥兰,去河邊找鬼弄屡。 笑死题禀,一個胖子當著我的面吹牛鞋诗,可吹牛的內容都是我干的。 我是一名探鬼主播迈嘹,決...
    沈念sama閱讀 38,340評論 3 399
  • 文/蒼蘭香墨 我猛地睜開眼削彬,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了秀仲?” 一聲冷哼從身側響起融痛,我...
    開封第一講書人閱讀 36,973評論 0 259
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎神僵,沒想到半個月后雁刷,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經...
    沈念sama閱讀 43,466評論 1 300
  • 正文 獨居荒郊野嶺守林人離奇死亡保礼,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 35,937評論 2 323
  • 正文 我和宋清朗相戀三年沛励,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片炮障。...
    茶點故事閱讀 38,039評論 1 333
  • 序言:一個原本活蹦亂跳的男人離奇死亡目派,死狀恐怖,靈堂內的尸體忽然破棺而出胁赢,到底是詐尸還是另有隱情企蹭,我是刑警寧澤,帶...
    沈念sama閱讀 33,701評論 4 323
  • 正文 年R本政府宣布,位于F島的核電站谅摄,受9級特大地震影響徒河,放射性物質發(fā)生泄漏。R本人自食惡果不足惜螟凭,卻給世界環(huán)境...
    茶點故事閱讀 39,254評論 3 307
  • 文/蒙蒙 一虚青、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧螺男,春花似錦棒厘、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,259評論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至淆院,卻和暖如春何乎,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背土辩。 一陣腳步聲響...
    開封第一講書人閱讀 31,485評論 1 262
  • 我被黑心中介騙來泰國打工支救, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人拷淘。 一個月前我還...
    沈念sama閱讀 45,497評論 2 354
  • 正文 我出身青樓各墨,卻偏偏與公主長得像,于是被迫代替她去往敵國和親启涯。 傳聞我的和親對象是個殘疾皇子贬堵,可洞房花燭夜當晚...
    茶點故事閱讀 42,786評論 2 345

推薦閱讀更多精彩內容