原文: 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ù)都時刻準備接收來自O(shè)bservable流推送的不同消息。

Observer在RxJS中是被優(yōu)待的。如果沒有為某個類型的通知提供callback，Observable流的執(zhí)行過程仍然會照常進行，但是響應(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') );

總結(jié)

以上是生活随笔為你收集整理的[译]RxJS文档04——Observer 观察者的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。