[譯]RxJS文檔04——Observer 觀察者

xiaolinbang 發(fā)布于2019-08-20 17:30 / 855人閱讀

摘要：原文什么是觀察者是流推送數(shù)據(jù)的用戶。觀察者們就是一組函數(shù)的集合，監(jiān)聽著每一個流推送出的不同類型的通知，包括和。如果沒有為某個類型的通知提供，流的執(zhí)行過程仍然會照常進(jìn)行，但是響應(yīng)的通知將會被忽略，因為觀察者沒有提供相應(yīng)的來接收。

原文: http://reactivex.io/rxjs/manu...

什么是Observer？ 觀察者(Observer)是Observable流推送數(shù)據(jù)的用戶。觀察者們(Observers)就是一組callback函數(shù)的集合，監(jiān)聽著每一個Observable流推送出的不同類型的通知，包括:next,error和complete。

以下是一個經(jīng)典的觀察者對象:

var observer = {
  next: x => console.log("Observer got a next value: " + x),
  error: err => console.error("Observer got an error: " + err),
  complete: () => console.log("Observer got a complete notification"),
};

為了使用觀察者，需要讓他訂閱一個Observable流：

observable.subscribe(observer);

觀察者是一個包含三個回調(diào)函數(shù)的對象，每一個函數(shù)都時刻準(zhǔn)備接收來自O(shè)bservable流推送的不同消息。

Observer在RxJS中是被優(yōu)待的。如果沒有為某個類型的通知提供callback，Observable流的執(zhí)行過程仍然會照常進(jìn)行，但是響應(yīng)的通知將會被忽略，因為觀察者沒有提供相應(yīng)的callback來接收。

下面是一個Observer沒有提供complete響應(yīng)(callback)的例子：

var observer = {
  next: x => console.log("Observer got a next value: " + x),
  error: err => console.error("Observer got an error: " + err),
};

訂閱一個Observable流的時候，你也可以只提供一個callback函數(shù)作為參數(shù)，而不用完整提供一個包含三個回調(diào)的對象，就像下面的例子:

observable.subscribe(x => console.log("Observer got a next value: " + x));

在observable.subscribe()內(nèi)部，將會創(chuàng)建一個觀察者對象(Observer object)，并將第一個參數(shù)提供的callback作為next通知的響應(yīng)函數(shù)。接受三個類型通知的callback也可以分別以參數(shù)的形式提供:

observable.subscribe(
  x => console.log("Observer got a next value: " + x),
  err => console.error("Observer got an error: " + err),
  () => console.log("Observer got a complete notification")
);