今天介紹「條件/布林類型」的 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

findIndex 與 find 一樣需要一個 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 的事件是否「全部符合指定條件」。

相關資源

• Operator - isEmpty
• Operator - defaultIfEmpty
• Operator - find
• Operator - findIndex
• Operator - every