新概念:
在 RxJS 中用來解決異步事件管理的的基本概念是:
Observable (可觀察對(duì)象): 表示一個(gè)概念,這個(gè)概念是一個(gè)可調(diào)用的未來值或事件的集合奴烙。
Observer (觀察者): 一個(gè)回調(diào)函數(shù)的集合助被,它知道如何去監(jiān)聽由 Observable 提供的值。
Subscription (訂閱): 表示 Observable 的執(zhí)行切诀,主要用于取消 Observable 的執(zhí)行揩环。
Operators (操作符): 采用函數(shù)式編程風(fēng)格的純函數(shù) (pure function),使用像 map幅虑、filter丰滑、concat、flatMap 等這樣的操作符來處理集 合倒庵。
Subject (主體): 相當(dāng)于 EventEmitter褒墨,并且是將值或事件多路推送給多個(gè) Observer 的唯一方式。
Schedulers (調(diào)度器): 用來控制并發(fā)并且是中央集權(quán)的調(diào)度員擎宝,允許我們?cè)诎l(fā)生計(jì)算時(shí)進(jìn)行協(xié)調(diào)郁妈,例如 setTimeout 或 requestAnimationFrame 或其他。
subscribe 調(diào)用在同一 Observable 的多個(gè)觀察者之間是不共享的绍申。當(dāng)使用一個(gè)觀察者調(diào)用 observable.subscribe 時(shí)噩咪,Observable.create(function subscribe(observer) {...}) 中的 subscribe 函數(shù)只服務(wù)于給定的觀察者顾彰。對(duì) observable.subscribe 的每次調(diào)用都會(huì)觸發(fā)針對(duì)給定觀察者的獨(dú)立設(shè)置。
與Observable 不一樣:
Subject 是一種特殊類型的 Observable胃碾,它允許將值多播給多個(gè)觀察者涨享,所以 Subject 是多播的,而普通的 Observables 是單播的(每個(gè)已訂閱的觀察者都擁有 Observable 的獨(dú)立執(zhí)行)书在。
Subject 的其中一個(gè)變體就是 BehaviorSubject灰伟,它有一個(gè)“當(dāng)前值”的概念。它保存了發(fā)送給消費(fèi)者的最新值儒旬。并且當(dāng)有新的觀察者訂閱時(shí)栏账,會(huì)立即從 BehaviorSubject 那接收到“當(dāng)前值”。
ReplaySubject 類似于 BehaviorSubject栈源,它可以發(fā)送舊值給新的訂閱者挡爵,但它還可以記錄 Observable 執(zhí)行的一部分。
AsyncSubject 是另一個(gè) Subject 變體甚垦,只有當(dāng) Observable 執(zhí)行完成時(shí)(執(zhí)行 complete())茶鹃,它才會(huì)將執(zhí)行的最后一個(gè)值發(fā)送給觀察者。
4.操作符
操作符是允許復(fù)雜的異步代碼以聲明式的方式進(jìn)行輕松組合的基礎(chǔ)代碼單元艰亮。
訂閱 output 會(huì)導(dǎo)致 input Observable 也被訂閱闭翩。我們稱之為“操作符訂閱鏈”。
實(shí)例運(yùn)算符是使用 this 關(guān)鍵字來指代輸入的 Observable 的函數(shù)迄埃。
靜態(tài)操作符是附加到 Observalbe 類上的純函數(shù)疗韵,通常用來從頭開始創(chuàng)建 Observalbe 。
5.調(diào)度器
調(diào)度器控制著何時(shí)啟動(dòng) subscription 和何時(shí)發(fā)送通知侄非。它由三部分組成:
調(diào)度器是一種數(shù)據(jù)結(jié)構(gòu)蕉汪。 它知道如何根據(jù)優(yōu)先級(jí)或其他標(biāo)準(zhǔn)來存儲(chǔ)任務(wù)和將任務(wù)進(jìn)行排序。
調(diào)度器是執(zhí)行上下文逞怨。 它表示在何時(shí)何地執(zhí)行任務(wù)(舉例來說者疤,立即的,或另一種回調(diào)函數(shù)機(jī)制(比如 setTimeout 或 process.nextTick)叠赦,或動(dòng)畫幀)驹马。
調(diào)度器有一個(gè)(虛擬的)時(shí)鐘。 調(diào)度器功能通過它的 getter 方法 now() 提供了“時(shí)間”的概念除秀。在具體調(diào)度器上安排的任務(wù)將嚴(yán)格遵循該時(shí)鐘所表示的時(shí)間窥翩。
調(diào)度器可以讓你規(guī)定 Observable 在什么樣的執(zhí)行上下文中發(fā)送通知給它的觀察者。
靜態(tài)創(chuàng)建操作符通沉巯桑可以接收調(diào)度器作為參數(shù)。
使用 subscribeOn 來調(diào)度 subscribe() 調(diào)用在什么樣的上下文中執(zhí)行笔时。
使用 observeOn 來調(diào)度發(fā)送通知的的上下文棍好。
實(shí)例操作符可能會(huì)接收調(diào)度器作為參數(shù)。