這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)Observable怎么在Angular中使用,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
創(chuàng)新互聯(lián)主營北塔網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,app開發(fā)定制,北塔h5成都微信小程序搭建,北塔網(wǎng)站營銷推廣歡迎北塔等地區(qū)企業(yè)咨詢
可觀察對象(Observable)
可觀察對象支持在應(yīng)用的發(fā)布者和訂閱者之間傳遞消息。
可觀察對象是聲明式的 —— 即定義的用于發(fā)布值的函數(shù),在有消費(fèi)者訂閱它之前,這個(gè)函數(shù)不會(huì)實(shí)際執(zhí)行。
可觀察對象可能會(huì)發(fā)出的三種通知:
通知類型 | 說明 |
---|---|
next | 必要。用來處理每個(gè)送達(dá)值。在開始執(zhí)行后可能執(zhí)行零次或多次。 |
error | 可選。用來處理錯(cuò)誤通知。錯(cuò)誤會(huì)中斷這個(gè)可觀察對象實(shí)例的執(zhí)行過程。 |
complete | 可選。用來處理執(zhí)行完畢(complete)通知。當(dāng)執(zhí)行完畢后,這些值就會(huì)繼續(xù)傳給下一個(gè)處理器。 |
定義觀察者
觀察者(observer):用于接收可觀察對象通知的處理器要實(shí)現(xiàn) Observer 接口,這個(gè)對象定義了一些回調(diào)函數(shù)來處理可觀察對象可能會(huì)發(fā)來的三種通知。
觀察者對象可以定義這三種處理器的任意組合。如果你不為某種通知類型提供處理器,這個(gè)觀察者就會(huì)忽略相應(yīng)類型的通知。
// Create observer object const myObserver = { next: (_data) => { // next通知類型處理器 }, error: err => { // error通知類型處理器 }, complete: () => console.log('Observer got a complete notification'), };
訂閱
只有當(dāng)Observable的實(shí)例被訂閱時(shí),Observable實(shí)例才會(huì)發(fā)布值。訂閱時(shí)要先調(diào)用該實(shí)例的subscribe()方法,并把一個(gè)觀察者對象傳給它,用來接收通知。
語法:Observable.subscribe(ObserverObject)
,其中,Observable為可觀察對象實(shí)例,ObserverObject為觀察者對象。
// 官網(wǎng)示例 // Create simple observable that emits three values const myObservable = of(1, 2, 3); // Create observer object const myObserver = { 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'), }; // Execute with the observer object myObservable.subscribe(myObserver); // Logs: // Observer got a next value: 1 // Observer got a next value: 2 // Observer got a next value: 3 // Observer got a complete notification
另外,subscribe() 方法還可以接收定義在同一行中的回調(diào)函數(shù),無論 next、error 還是 complete 處理器。比如,下面的 subscribe() 調(diào)用和前面指定預(yù)定義觀察者的例子是等價(jià)的。
myObservable.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') );
注:無論哪種情況,next通知類型的處理器是必要的,而error和complete處理器是可選的。
subscribe() 調(diào)用會(huì)返回一個(gè) Subscription 對象,該對象具有一個(gè) unsubscribe()
方法。 當(dāng)調(diào)用該方法時(shí),你就會(huì)停止接收通知。
上述就是小編為大家分享的Observable怎么在Angular中使用了,如果剛好有類似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。