Rxjs?TakeUntil?操作符內(nèi)容梳理總結(jié)
TakeUntil 的官方文檔對(duì)這個(gè)操作符的解釋是:
Emit values until provided observable emits.
即它可以被賦予另一個(gè)起錨定作用的 Observable,當(dāng)該錨定 Observable emit 值時(shí),原始的 Observable 就停止發(fā)射值,進(jìn)入 complete 操作。
看一個(gè)實(shí)際的例子:
import { interval, timer } from 'rxjs'; import { takeUntil } from 'rxjs/operators'; //emit value every 1s const source = interval(1000); //after 5 seconds, emit value const timer$ = timer(5000); //when timer emits after 5s, complete source const example = source.pipe(takeUntil(timer$)); //output: 0,1,2,3 const subscribe = example.subscribe(val => console.log(val));
source Observable 每個(gè)1秒的時(shí)間間隔,發(fā)射一個(gè)從 0 開(kāi)始遞增間隔為 1 的整數(shù)序列。
我們構(gòu)造了一個(gè) timer Observable,超時(shí)時(shí)間間隔為 5 秒,也就是說(shuō),在第五秒時(shí),該 Observable 會(huì)發(fā)送一個(gè)值。這個(gè) timer Observable 傳入 takeUntil,作為一個(gè) notification Observable,五秒鐘之后,source Observable 就會(huì)停止發(fā)射整數(shù)。
最后上述程序執(zhí)行的輸出:4 秒之內(nèi)打印 0~4,然后結(jié)束。
另一個(gè)例子:
const interval = interval(1000); const clicks = fromEvent(document, 'click'); const result = interval.pipe(takeUntil(clicks)); result.subscribe(x => console.log(x));
這個(gè)例子里,interval 作為原始的 Observable,clicks 作為 notification Observable,整個(gè)程序的表現(xiàn)形式是,每個(gè) 1 秒有一個(gè)遞增1的整數(shù)序列打印,直至頁(yè)面發(fā)生點(diǎn)擊事件時(shí),原始 interval Observable 終止。
看另一個(gè)例子:
// RxJS v6+ import { interval } from 'rxjs/observable/interval'; import { takeUntil, filter, scan, map, withLatestFrom } from 'rxjs/operators'; //emit value every 1s const source = interval(1000); //is number even? const isEven = val => val % 2 === 0; //only allow values that are even const evenSource = source.pipe(filter(isEven)); //keep a running total of the number of even numbers out const evenNumberCount = evenSource.pipe(scan((acc, _) => acc + 1, 0)); //do not emit until 5 even numbers have been emitted const fiveEvenNumbers = evenNumberCount.pipe(filter(val => val > 5)); const example = evenSource.pipe( //also give me the current even number count for display withLatestFrom(evenNumberCount), map(([val, count]) => `Even number (${count}) : ${val}`), //when five even numbers have been emitted, complete source observable takeUntil(fiveEvenNumbers) ); /* Even number (1) : 0, Even number (2) : 2 Even number (3) : 4 Even number (4) : 6 Even number (5) : 8 */ const subscribe = example.subscribe(val => console.log(val));
我們逐行分析這個(gè)例子的邏輯:
const evenSource = source.pipe(filter(isEven));
產(chǎn)生一個(gè)每隔1秒發(fā)射一個(gè)偶數(shù)的 Observable.
const evenNumberCount = evenSource.pipe(scan((acc, _) => acc + 1, 0));
對(duì)產(chǎn)生的偶數(shù)的個(gè)數(shù)進(jìn)行累加。
const fiveEvenNumbers = evenNumberCount.pipe(filter(val => val > 5));
當(dāng)產(chǎn)生的偶數(shù)個(gè)數(shù)大于 5 時(shí),發(fā)射值。這個(gè) Observable 作為 takeUntil 的 notification Observable 使用。
const example = evenSource.pipe( //also give me the current even number count for display withLatestFrom(evenNumberCount), map(([val, count]) => `Even number (${count}) : ${val}`), //when five even numbers have been emitted, complete source observable takeUntil(fiveEvenNumbers) );
- 使用 eventSource 和 eventNumberCount,通過(guò)
withLatestFrom
將兩個(gè) Observable 進(jìn)行連接,從而在 map Operator 里,可以同時(shí)打印出當(dāng)前發(fā)射的偶數(shù)值和偶數(shù)總量。通過(guò) takeUntil 傳入一個(gè)只有在偶數(shù)總數(shù)個(gè)數(shù)大于 5 時(shí)才發(fā)射值的 Observable,可以做到偶數(shù)總數(shù)大于 5 之后,讓 interval 停止值的發(fā)送。
最后的執(zhí)行效果:
到此這篇關(guān)于Rxjs TakeUntil 操作符內(nèi)容梳理總結(jié)的文章就介紹到這了,更多相關(guān)Rxjs TakeUntil 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
javascript實(shí)現(xiàn)數(shù)字時(shí)鐘效果
這篇文章主要為大家詳細(xì)介紹了javascript實(shí)現(xiàn)數(shù)字時(shí)鐘效果,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-02-02利用ajaxfileupload插件實(shí)現(xiàn)文件上傳無(wú)刷新的具體方法
利用ajaxfileupload插件實(shí)現(xiàn)文件上傳無(wú)刷新的具體方法,需要的朋友可以參考一下2013-06-06JavaScript獲取頁(yè)面中超鏈接數(shù)量的方法
這篇文章主要介紹了JavaScript獲取頁(yè)面中超鏈接數(shù)量的方法,涉及JavaScript針對(duì)頁(yè)面元素獲取及運(yùn)算的相關(guān)實(shí)現(xiàn)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-11-11js實(shí)現(xiàn)的點(diǎn)擊超鏈顯示隱藏層
js實(shí)現(xiàn)的點(diǎn)擊超鏈顯示隱藏層...2007-05-05javascript的trim,ltrim,rtrim自定義函數(shù)
今天用到j(luò)avascript去掉一個(gè)文本框中字符串兩端的空格,開(kāi)始還以為有trim,ltrim,rtrim函數(shù)(asp中有這三個(gè)函數(shù),弄混了),結(jié)果找半天,沒(méi)有找到。最后找到用正則實(shí)現(xiàn)這樣功能的自定義函數(shù)。2008-09-09javascript實(shí)現(xiàn)了照片拖拽點(diǎn)擊置頂?shù)恼掌瑝Υa
這篇文章主要介紹了javascript實(shí)現(xiàn)了照片拖拽點(diǎn)擊置頂?shù)恼掌瑝Υa,效果非常不錯(cuò),這里推薦給大家,有需要的小伙伴可以參考下。2015-04-04微信小程序?qū)崿F(xiàn)簡(jiǎn)易計(jì)算器
這篇文章介紹了微信小程序?qū)崿F(xiàn)簡(jiǎn)易計(jì)算器的方法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-06-06