1.Observable：可觀察對象—一個(gè)值或事件的流集合；
（1） 創(chuàng)建：Rx.Observable.create()/of()/from()等娱挨；
（2）訂閱：subscrible()—每次調(diào)用都會有一個(gè)新的觀察者，數(shù)據(jù)不共享堵漱；相當(dāng)于調(diào)用創(chuàng)建Observables的參數(shù)函數(shù)祷愉，并提供接收數(shù)據(jù)的回調(diào)函數(shù)；
（3）執(zhí)行：可觀察者對象實(shí)例.next()/error()/complete()—相當(dāng)于return湖雹；可以發(fā)送多個(gè)next通知咏闪，但若發(fā)送的是error/complete通知，則之后不會再發(fā)送任何通知了摔吏；
（4）清理：unsubscribe()
（5）hot Observable vs cold Observable
-
hot Observable：內(nèi)容創(chuàng)建與訂閱者無關(guān)鸽嫂，實(shí)現(xiàn)多播，即無論多少個(gè)oberser來subscribe征讲，推給observer的都是一樣的數(shù)據(jù)源据某，若無訂閱者探孝，數(shù)據(jù)依然會產(chǎn)生孩锡，只是不傳入數(shù)據(jù)通道减牺；
- 創(chuàng)建操作符：fromPromise摄乒、fromEvent捞慌、fromEventPattern陋气；
cold Observable：每次被subscribe都產(chǎn)生一個(gè)全新的數(shù)據(jù)流动看，實(shí)現(xiàn)單播恃鞋，若無訂閱者匠童，連數(shù)據(jù)都不會產(chǎn)生埂材；
2.Observer：觀察者—三個(gè)回掉函數(shù)的集合對象next()：接收Observable發(fā)出的值；
error()：接收錯誤汤求；
-
complete()：當(dāng)沒有新的數(shù)據(jù)發(fā)出時(shí)俏险，觸發(fā)操作严拒；
（1）先聲明observer對象，再傳入subscribe()做參數(shù)竖独；
聲明觀察者對象
傳入subscribe()
（2）在subscribe()內(nèi)部寫回調(diào)函數(shù)裤唠，它會創(chuàng)建一個(gè)觀察者對象；
封裝為observer
3.Subscription：訂閱—Observable的執(zhí)行预鬓，當(dāng)Observable變化時(shí)巧骚，調(diào)用observer提供的方法通知他；
（1）訂閱Observable類似于函數(shù)調(diào)用格二；
（2）unsubscribe()清理Subscription占用的資源劈彪；
4.Subject：主體—同一個(gè)Observable可以被多個(gè)observer訂閱，subject可以向多個(gè)observer多路推送數(shù)值顶猜；
（1）每個(gè)Subject即是Observable也是Observer沧奴；
-
Subject不能重復(fù)使用，一旦Subject對象調(diào)用了complete/error函數(shù)长窄，則它作為Observable的生命周期也就結(jié)束了滔吠；
observerA:1, observerB:1, observerA:2, observerB:2
observerA:1, observerB:1, observerA: 2, observerB:2, observerA:3, observerB:3
（2）BehaviorSubject：保存發(fā)送給消費(fèi)者的最新值(初始值是0)，并且當(dāng)有新的觀察者訂閱時(shí)挠日，會立即接收到該最新值疮绷；
- publishBehavior()：返回一個(gè)BehaviorSubject，當(dāng)訂閱時(shí)可立即獲得上游吐出的最新值嚣潜；
（3）ReplaySubject：記錄Observable執(zhí)行中的多個(gè)值并將其回放給訂閱者
-
創(chuàng)建時(shí)指定回放值的個(gè)數(shù)冬骚；
為新的訂閱者緩存三個(gè)值—observerA:1, observerA:2, observerA:3, observerA:4, observerB:2, observerB:3, observerB:4, observerA:5, observerB:5 -
指定window time來確定記錄多久以前的值；
最大緩存數(shù)量是100懂算，window time是500ms - publishReply(n)：返回一個(gè)ReplaySubject只冻，當(dāng)訂閱時(shí)緩存上游數(shù)據(jù)流中的n個(gè)數(shù)據(jù)；
（4）AsyncSubject：等待Observable發(fā)出complete通知后计技，才發(fā)送最后一個(gè)單個(gè)值喜德；
- publishLast()：返回一個(gè)AsyncSubject，訂閱時(shí)只獲取上游數(shù)據(jù)的最后一個(gè)值垮媒；
（5）refCount()：當(dāng)observable有訂閱后才會自動打開廣播功能舍悯，當(dāng)沒有訂閱后，會自動關(guān)閉涣澡；
（6）publish()
5.Operators：操作符—接收傳入的Observable贱呐，返回新的Observable；
6.Scheduler：調(diào)度器— 改變Observable對象吐數(shù)據(jù)的節(jié)奏入桂；
（1）實(shí)例
- undefined/null：即不指定scheduler奄薇，代表同步執(zhí)行的scheduler；
- asap：利用事件循環(huán)實(shí)現(xiàn)異步抗愁，使用的是micro task馁蒂；
- async：利用事件循環(huán)實(shí)現(xiàn)異步呵晚，使用的是macro task；
- queue：同步執(zhí)行沫屡；
- animationFrame：用于動畫場景的scheduler饵隙；
[總結(jié)]Observable實(shí)例對象只是聲明不執(zhí)行，只有訂閱subscribe是才執(zhí)行其參數(shù)函數(shù)沮脖，若內(nèi)部傳出出來會調(diào)用subscribe的回調(diào)函數(shù)金矛；
