RXJava Subject詳解 (RXJava Part 2)

前面說過了RXJava中的Observable磅网,本次來說說Subject。
附上前文的鏈接嵌施。喜歡的兄弟麻煩點(diǎn)個(gè)喜歡违帆,關(guān)注啥的吧剃根。
RXJava Observable詳解 (RXJava Part 1)

Subject

Subject有兩種用途:

  1. 做為observable向其他的observable發(fā)送事件
  2. 做為observer接收其他的observable發(fā)送的事件。
    最后的一個(gè)例子會(huì)使用一個(gè)subject監(jiān)聽一個(gè)observable前方,并將observable發(fā)射的事件轉(zhuǎn)發(fā)給一個(gè)observer狈醉。

Subject做為Observable

  • PublishSubject

該Subject不會(huì)改變事件的發(fā)送順序。
如果在已經(jīng)發(fā)送了一部分事件之后注冊(cè)的observer惠险,
是不會(huì)收到之前發(fā)送的事件苗傅。

重點(diǎn)跟下面三個(gè)類作對(duì)比

    private void doPublishSubject() {
        //將事件發(fā)送到observer,如果先前已經(jīng)漏掉的事件班巩,不會(huì)重新發(fā)送到后注冊(cè)的observer上
        PublishSubject<String> publish = PublishSubject.create();
        publish.subscribe(new PublishObserver<String>("first"));
        publish.onNext("1");
        publish.onNext("2");
        publish.subscribe(new PublishObserver<String>("seconde"));
        publish.onNext("3");
        publish.onCompleted();
    }
    
    class SubjectObserver<T extends String> implements Observer<String> {

    String name;

    public SubjectObserver(String name) {
        this.name = name;
    }

    @Override
    public void onCompleted() {
        LogUtils.d("publishObserver %s is completed", name);
    }

    @Override
    public void onError(Throwable e) {
        LogUtils.d("publishObserver %s error msg %s", name, e.getStackTrace());
    }

    @Override
    public void onNext(java.lang.String s) {
        LogUtils.d("publishObserver %s receive msg %s", name, s);
    }
}

  • BehaviorSubject

該類有創(chuàng)建時(shí)需要一個(gè)默認(rèn)參數(shù)渣慕,該默認(rèn)參數(shù)會(huì)在subject未發(fā)送過其他的事件時(shí),向注冊(cè)的observer發(fā)送抱慌。
注意看代碼注釋逊桦。

    private void doBehaviorSubject() {
        //將事件發(fā)送到observer,如果先前已經(jīng)漏掉的事件抑进,除了最近的一個(gè)事件以外强经,
        //其他相關(guān)事件不會(huì)重新發(fā)送到后注冊(cè)的observer上。所以需要帶默認(rèn)值寺渗,
        //第一次被observer注冊(cè)時(shí)匿情,observable中沒有內(nèi)容的時(shí)候,就會(huì)將默認(rèn)值發(fā)給observer
        BehaviorSubject<String> behavior = BehaviorSubject.create("創(chuàng)建beahavior時(shí)候帶的消息");
        behavior.subscribe(new SubjectObserver<String>("first"));
        behavior.onNext("1");
        behavior.onNext("2");
        behavior.subscribe(new SubjectObserver<String>("seconde"));
        behavior.onNext("3");
        behavior.onCompleted();
    }
  • ReplaySubject

將事件發(fā)送到observer信殊,無論什么時(shí)候注冊(cè)observer炬称,
無論何時(shí)通過該observable發(fā)射的所有事件,均會(huì)發(fā)送給新的observer涡拘。

    private void doReplaySubject() {
        //將事件發(fā)送到observer玲躯,無論什么時(shí)候注冊(cè)observer,
        //無論何時(shí)通過該observable發(fā)射的所有事件,均會(huì)發(fā)送給新的observer跷车。
        ReplaySubject<String> replay = ReplaySubject.create();
        replay.subscribe(new SubjectObserver<String>("first"));
        replay.onNext("1");
        replay.onNext("2");
        replay.subscribe(new SubjectObserver<String>("seconde"));
        replay.onNext("3");
        replay.onCompleted();
    }
  • AsyncSubject

只有當(dāng)subject調(diào)用onComplete方法時(shí)晋控,才會(huì)將subject中的最后一個(gè)事件傳遞給observer。
如果不調(diào)用onComplete方法姓赤,則不會(huì)給observer發(fā)送任何事件。

    private void doAsyncSubject() {
        //只會(huì)有當(dāng)subject調(diào)用onComplete方法時(shí)仲吏,才會(huì)將subject中的最后一個(gè)事件傳遞給observer不铆。
        //如果不調(diào)用onComplete方法,則不會(huì)向observer中發(fā)送任何事件
        AsyncSubject async = AsyncSubject.create();
        async.subscribe(new SubjectObserver<String>("first"));
        async.onNext("1");
        async.onNext("2");
        async.onNext("3");
        async.onCompleted();
        async.subscribe(new SubjectObserver<String>("seconde"));
        async.onCompleted();
    }

Subject做為observable

文章開頭說了裹唆,subject及可以做observer也可以做observable誓斥。
示例會(huì)將subject注冊(cè)為一個(gè)observer來接收創(chuàng)建的observable中的事件。
并將observable中的事件再發(fā)送給在該Subject中注冊(cè)的observer中许帐。

  private void doObserverSubject() {
        //將Subject當(dāng)作Observer使用劳坑,并將另外的observer注冊(cè)到subject上,來監(jiān)聽原始的observable發(fā)出的事件
        List<String> items = new ArrayList<>();
        items.add("100");
        items.add("103");
        items.add("107");
        Observable<String> observable = Observable.from(items);
        ReplaySubject<String> replay = ReplaySubject.create();
        observable.subscribe(replay);
        replay.subscribe(new SubjectObserver<String>("first"));
    }

Android交流qq群號(hào) 29552133

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末成畦,一起剝皮案震驚了整個(gè)濱河市距芬,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌循帐,老刑警劉巖框仔,帶你破解...
    沈念sama閱讀 223,126評(píng)論 6 520
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異拄养,居然都是意外死亡离斩,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,421評(píng)論 3 400
  • 文/潘曉璐 我一進(jìn)店門瘪匿,熙熙樓的掌柜王于貴愁眉苦臉地迎上來吃谣,“玉大人混稽,你說我怎么就攤上這事。” “怎么了晋修?”我有些...
    開封第一講書人閱讀 169,941評(píng)論 0 366
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)掂林。 經(jīng)常有香客問我志鞍,道長(zhǎng),這世上最難降的妖魔是什么家乘? 我笑而不...
    開封第一講書人閱讀 60,294評(píng)論 1 300
  • 正文 為了忘掉前任蝗羊,我火速辦了婚禮,結(jié)果婚禮上仁锯,老公的妹妹穿的比我還像新娘耀找。我一直安慰自己,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,295評(píng)論 6 398
  • 文/花漫 我一把揭開白布野芒。 她就那樣靜靜地躺著蓄愁,像睡著了一般。 火紅的嫁衣襯著肌膚如雪狞悲。 梳的紋絲不亂的頭發(fā)上撮抓,一...
    開封第一講書人閱讀 52,874評(píng)論 1 314
  • 那天,我揣著相機(jī)與錄音摇锋,去河邊找鬼丹拯。 笑死,一個(gè)胖子當(dāng)著我的面吹牛荸恕,可吹牛的內(nèi)容都是我干的乖酬。 我是一名探鬼主播,決...
    沈念sama閱讀 41,285評(píng)論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼融求,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼咬像!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起生宛,我...
    開封第一講書人閱讀 40,249評(píng)論 0 277
  • 序言:老撾萬榮一對(duì)情侶失蹤县昂,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后陷舅,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體七芭,經(jīng)...
    沈念sama閱讀 46,760評(píng)論 1 321
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,840評(píng)論 3 343
  • 正文 我和宋清朗相戀三年蔑赘,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了狸驳。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,973評(píng)論 1 354
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡缩赛,死狀恐怖耙箍,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情酥馍,我是刑警寧澤辩昆,帶...
    沈念sama閱讀 36,631評(píng)論 5 351
  • 正文 年R本政府宣布,位于F島的核電站旨袒,受9級(jí)特大地震影響汁针,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜砚尽,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,315評(píng)論 3 336
  • 文/蒙蒙 一施无、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧必孤,春花似錦猾骡、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,797評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽幢哨。三九已至,卻和暖如春嫂便,著一層夾襖步出監(jiān)牢的瞬間捞镰,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,926評(píng)論 1 275
  • 我被黑心中介騙來泰國打工毙替, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留岸售,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 49,431評(píng)論 3 379
  • 正文 我出身青樓蔚龙,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國和親映胁。 傳聞我的和親對(duì)象是個(gè)殘疾皇子木羹,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,982評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容