[RxJS] 條件/布林類型 Operators (1) - isEmpty / defaultIfEmpty / find / finxIndex / every

|

今天介紹「條件/布林類型」的 operators,這類型的 operators 都是用來判斷整個 Observable 是否符合某些條件來當作新的 Observable 事件資料。

isEmpty

isEmpty 會判斷來源 Observable 是否沒有「發生過任何事件值」,如果到結束時完全沒有任何事件發生過,則會發生 true 事件在新的 Observable 上,反之則新的 Observable 會發生 false 事件。

EMPTY
  .pipe(isEmpty())
  .subscribe(data => {
    console.log(`isEmpty 示範 (1): ${data}`)
  });
// isEmpty 示範 (1): true

const emptySource$ = new Subject();
emptySource$
  .pipe(isEmpty())
  .subscribe(data => {
    console.log(`isEmpty 示範 (2): ${data}`)
  });
setTimeout(() => emptySource$.complete(), 2000);
// isEmpty 示範 (2): true

上面程式中,我們建立兩種 Observable,一種是使用 EMPTY 直接建立一個空的 Observable,第二種是使用 Subject 建立 Observable,但沒有讓任何事件發生,並在兩秒後結束;由於兩種 Observable 過程中都沒有任合新的事件發生,因此最終會得到 true 的結果。

彈珠圖:

-----------|
isEmpty()
-----------(true|)

如果過程中有發生過事件呢?當然就會得到 false 的結果:

interval(1000)
  .pipe(
    take(3),
    isEmpty()
  )
  .subscribe(data => {
    console.log(`isEmpty 示範 (3): ${data}`)
  });
// isEmpty 示範 (3): false

由於有事件發生,確定不是空的 Observable,因此在事件發生同時,就會得到 false 同時結束 Observable。

彈珠圖:

---0---1---2---3---4---5...
take(3)
---0---1---2|
isEmpty()
---(false|)

程式碼:https://stackblitz.com/edit/mastering-rxjs-operator-isempty

defaultIfEmpty

defaultIfEmpty 會在 Observable 沒有任何事件發生就結束時,給予一個預設值:

const emptySource$ = new Subject();
emptySource$
  .pipe(defaultIfEmpty('a'))
  .subscribe(data => {
    console.log(`defaultIfEmpty 示範 (1): ${data}`)
  });
setTimeout(() => emptySource$.complete(), 2000);
// defaultIfEmpty 示範 (1): a

上面程式中,由於來源 Observable 是一個空的 Observable,因此會給予一個指定的預設值。

彈珠圖:

------|
defaultIfEmpty('a')
------(a|)

如果過程中有發生事件值呢?那麼當然 defaultIfEmpty 就不做任何事情囉:

interval(1000)
  .pipe(
    take(3),
    defaultIfEmpty(-1) // 因為來源 Observable 有事件值,因此不做任何事情
  )
  .subscribe(data => {
    console.log(`defaultIfEmpty 示範 (2): ${data}`);
  });
// defaultIfEmpty 示範 (2): 0
// defaultIfEmpty 示範 (2): 1
// defaultIfEmpty 示範 (2): 2

程式碼:https://stackblitz.com/edit/mastering-rxjs-operator-defaultifempty

find

find 內需要傳入一個 predictate callback function,find 會將事件資訊傳入此 function,並回傳是否符合指定的條件,如果符合,就會將目前的事件資料發生在新的 Observable 上,同時完成 Observable。

interval(1000)
  .pipe(find(data => data === 3))
  .subscribe(data => {
    console.log(`find 示範: ${data}`);
  });
// find 示範: 3

上述程式的來源是一個每秒發生一次且不會結束的 Observable,透過 find,當符合資料等於 3 時,就使用這個資料作為新的 Observable 事件資料,同時結束整個 Observable。

彈珠圖:

---0---1---2---3---4---5.....
find(data => data === 3)
---------------(3|)

程式碼:https://stackblitz.com/edit/mastering-rxjs-operator-find

findIndex

findIndexfind 一樣需要一個 predicate callback function,差別在於 findIndex 的條件符合時,新的 Observable 事件資料是「符合條件事件的索引值」,也就是這個事件是來源 Observable 的第幾次事件:

interval(1000)
  .pipe(
    map(data => data * 2),
    findIndex(data => data === 6)
  )
  .subscribe(data => {
    console.log(`findIndex 示範: ${data}`);
  });
// findIndex 示範: 3

上面程式中,符合條件的資料為 6 因此將它發生在來源 Observable 的索引值 3 發生在新的 Observable 上,同時結束。

彈珠圖:

---0---1---2---3---4-...
map(data => daya * 3)
---0---2---4---6---8-...
findIndex(data => data === 6)
---------------(3|)
                ^ 來源資料的索引值

程式碼:https://stackblitz.com/edit/mastering-rxjs-operator-findindex

every

every 也是傳入一個 predicate callback function,every 會將事件資訊傳入此 function,並判斷來源 Observable 是否「全部符合指定條件」,如果符合,在來源 Observable 結束時會得到 true 事件;如果不符合,則會在事件資料不符合指定條件同時得到 false 事件並結束。

const source$ = interval(1000)
  .pipe(
    map(data => data * 2),
    take(3)
  );

source$
  .pipe(
    every(data => data % 2 === 0)
  )
  .subscribe(data => {
    console.log(`every 示範 (1): ${data}`);
  });
// every 示範 (1): true

上面程式的 source$ 資料都會是 2 的倍數,符合 every 內條件,因此在 Observable 結束時,會得到 true 事件。

彈珠圖:

---0---2---4|
every(data => data % 2 === 0)
-----------(true|)

當有事件值不符合時,會立刻收到此事件並結束。

interval(1000)
  .pipe(every(data => data % 2 === 0))
  .subscribe(data => {
    console.log(`every 示範 (2): ${data}`);
  });
// every 示範 (2): false

彈珠圖:

---0---1---2---3....
every(data => data % 2 === 0)
-------(false|)

程式碼:https://stackblitz.com/edit/mastering-rxjs-operator-every

本日小結

  • isEmpty:用來判斷來源 Observable 是否是空的,也就是沒有任何事件發生就結束了。
  • defaultIfEmpty:當來源 Observable 是空的時候,給予一個預設值。
  • find:用來判斷來源 Observable 是否有符合條件的事件資料,如果有,將此事件資料發生在新的 Observable 上,並結束。
  • findIndex:用來判斷來源 Observable 是否有符合條件的事件資料,如果有,將此事件資料在來源 Observable 的索引值發生在新的 Observable 上,並結束。
  • every:用來判斷來源 Observable 的事件是否「全部符合指定條件」。

相關資源

如果您覺得我的文章有幫助,歡迎免費成為 LikeCoin 會員,幫我的文章拍手 5 次表示支持!
[RxJS] 過濾類型 Operators (5) - sampleTime / sample / auditTime / audit / debounceTime / debounce
[RxJS] 數學/聚合類型 Operators (1) - min / max / count / reduce
[RxJS] 過濾類型 Operators (5) - sampleTime / sample / auditTime / audit / debounceTime / debounce
[RxJS] 數學/聚合類型 Operators (1) - min / max / count / reduce
按照日期
[RxJS] 過濾類型 Operators (5) - sampleTime / sample / auditTime / audit / debounceTime / debounce
[RxJS] 數學/聚合類型 Operators (1) - min / max / count / reduce

有任何問題或建議嗎?歡迎留言給我