RxJS 學習系列 11. 合并操作符 concat, merge, concatAll

這節(jié)講非常重要同時非常容易混淆的合并操作符凛膏,從名字上次都是合并,但是區(qū)別還是蠻大的,我會盡量結合Marble Diagram(彈珠圖)解釋清楚。

concat

首先登場的是concat阶捆,用來連接多個 observable。并順序依次執(zhí)行
特點:按照順序钦听,前一個 observable 完成了再訂閱下一個 observable 并發(fā)出值
注意事項:此操作符可以既有靜態(tài)方法洒试,又有實例方法
Marble Diagram:

source : ----0----1----2|
source2: (3)|
source3: (456)|
            concat()
example: ----0----1----2(3456)|

例子:

    const { concat } = rxjs.operators;
    const { of } = rxjs;

    const sourceOne = of(1, 2, 3);
    const sourceTwo = of(4, 5, 6);
    const sourceThree = of(7, 8);

    // 先發(fā)出 sourceOne 的值,當完成時訂閱 sourceTwo
    // 輸出: 1,2,3,4,5,6,7,8
    // 特點: 必須先等前一個 observable 完成(complete)朴上,才會繼續(xù)下一個
    sourceOne
      .pipe(
        concat(sourceTwo, sourceThree)
      )
      .subscribe(val =>
        console.log('Example: Basic concat:', val)
      );

    //  等價寫法垒棋, 把 concat 作為靜態(tài)方法使用,這樣更直觀
    rxjs
      .concat(sourceOne, sourceTwo)
      .subscribe(val =>
        console.log(val)
      );

merge

特點:merge 把多個 observable 同時處理痪宰,這跟 concat 一次處理一個 observable 是完全不一樣的叼架,由于是同時處理行為會變得較為復雜。
merge 的邏輯有點像是 OR(||)衣撬,就是當兩個 observable 其中一個被觸發(fā)時都可以被處理乖订,這很常用在一個以上的按鈕具有部分相同的行為。
同樣 既有靜態(tài)方法具练,又有實例方法

    rxjs
      .merge(
        interval(500).pipe(take(3)),
        interval(300).pipe(take(6)),
      )
      .subscribe(val =>
        console.log(val)
      );


    sourceOne
      .pipe(
        merge(sourceTwo)
      )
      .subscribe(val =>
        console.log(val)
      );

Marble Diagram:

source : ----0----1----2|
source2: --0--1--2--3--4--5|
            merge()
example: --0-01--21-3--(24)--5|

例如一個影片播放器有兩個按鈕乍构,一個是暫停(II),另一個是結束播放(口)靠粪。這兩個按鈕都具有相同的行為就是影片會被停止蜡吧,只是結束播放會讓影片回到 00 秒毫蚓,這時我們就可以把這兩個按鈕的事件 merge 起來處理影片暫停這件事。

var stopVideo = rxjs.merge(stopButton, endButton);
stopVideo.subscribe(() => {
    // 暫停播放影片
})

concatAll

有時我們的 Observable 送出的元素又是一個 observable昔善,就像是二維數(shù)組元潘,數(shù)組里面的元素是數(shù)組,這時我們就可以用 concatAll 把它攤平成一維數(shù)組君仆,大家也可以直接把 concatAll 想成把所有元素 concat 起來翩概。
特點:攤平 Observable

    // 我們每點擊一次 body 就會立刻送出 1,2,3
    fromEvent(document.body, 'click')
      .pipe(
        // 內部發(fā)出值是 observable 類型
        map(e => of(1,2,3)),
        // 取 observable 的值
        concatAll(),
      )
      .subscribe(val =>
        console.log(val)
      );
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市返咱,隨后出現(xiàn)的幾起案子钥庇,更是在濱河造成了極大的恐慌,老刑警劉巖咖摹,帶你破解...
    沈念sama閱讀 211,348評論 6 491
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件评姨,死亡現(xiàn)場離奇詭異,居然都是意外死亡萤晴,警方通過查閱死者的電腦和手機吐句,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,122評論 2 385
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來店读,“玉大人嗦枢,你說我怎么就攤上這事⊥投希” “怎么了文虏?”我有些...
    開封第一講書人閱讀 156,936評論 0 347
  • 文/不壞的土叔 我叫張陵,是天一觀的道長殖演。 經常有香客問我氧秘,道長,這世上最難降的妖魔是什么剃氧? 我笑而不...
    開封第一講書人閱讀 56,427評論 1 283
  • 正文 為了忘掉前任敏储,我火速辦了婚禮,結果婚禮上朋鞍,老公的妹妹穿的比我還像新娘已添。我一直安慰自己,他們只是感情好滥酥,可當我...
    茶點故事閱讀 65,467評論 6 385
  • 文/花漫 我一把揭開白布更舞。 她就那樣靜靜地躺著,像睡著了一般坎吻。 火紅的嫁衣襯著肌膚如雪缆蝉。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,785評論 1 290
  • 那天,我揣著相機與錄音刊头,去河邊找鬼黍瞧。 笑死,一個胖子當著我的面吹牛原杂,可吹牛的內容都是我干的印颤。 我是一名探鬼主播,決...
    沈念sama閱讀 38,931評論 3 406
  • 文/蒼蘭香墨 我猛地睜開眼穿肄,長吁一口氣:“原來是場噩夢啊……” “哼年局!你這毒婦竟也來了?” 一聲冷哼從身側響起咸产,我...
    開封第一講書人閱讀 37,696評論 0 266
  • 序言:老撾萬榮一對情侶失蹤矢否,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后脑溢,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體僵朗,經...
    沈念sama閱讀 44,141評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 36,483評論 2 327
  • 正文 我和宋清朗相戀三年焚志,在試婚紗的時候發(fā)現(xiàn)自己被綠了衣迷。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,625評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡酱酬,死狀恐怖,靈堂內的尸體忽然破棺而出云矫,到底是詐尸還是另有隱情膳沽,我是刑警寧澤,帶...
    沈念sama閱讀 34,291評論 4 329
  • 正文 年R本政府宣布让禀,位于F島的核電站挑社,受9級特大地震影響,放射性物質發(fā)生泄漏巡揍。R本人自食惡果不足惜痛阻,卻給世界環(huán)境...
    茶點故事閱讀 39,892評論 3 312
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望腮敌。 院中可真熱鬧阱当,春花似錦、人聲如沸糜工。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,741評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽捌木。三九已至油坝,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背澈圈。 一陣腳步聲響...
    開封第一講書人閱讀 31,977評論 1 265
  • 我被黑心中介騙來泰國打工彬檀, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人瞬女。 一個月前我還...
    沈念sama閱讀 46,324評論 2 360
  • 正文 我出身青樓窍帝,卻偏偏與公主長得像,于是被迫代替她去往敵國和親拆魏。 傳聞我的和親對象是個殘疾皇子盯桦,可洞房花燭夜當晚...
    茶點故事閱讀 43,492評論 2 348

推薦閱讀更多精彩內容