快捷導(dǎo)航

Rxjs?TakeUntil?操作符內(nèi)容梳理總結(jié)

更新時(shí)間：2022年06月27日 09:50:19 作者：??JerryWang_sap????

這篇文章主要介紹了Rxjs?TakeUntil操作符內(nèi)容梳理總結(jié)，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的小伙伴可以參考一下

TakeUntil 的官方文檔對這個(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 開始遞增間隔為 1 的整數(shù)序列。

我們構(gòu)造了一個(gè) timer Observable，超時(shí)時(shí)間間隔為 5 秒，也就是說，在第五秒時(shí)，該 Observable 會發(fā)送一個(gè)值。這個(gè) timer Observable 傳入 takeUntil，作為一個(gè) notification Observable，五秒鐘之后，source Observable 就會停止發(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ù)序列打印，直至頁面發(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));

對產(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，通過 withLatestFrom 將兩個(gè) Observable 進(jìn)行連接，從而在 map Operator 里，可以同時(shí)打印出當(dāng)前發(fā)射的偶數(shù)值和偶數(shù)總量。通過 takeUntil 傳入一個(gè)只有在偶數(shù)總數(shù)個(gè)數(shù)大于 5 時(shí)才發(fā)射值的 Observable，可以做到偶數(shù)總數(shù)大于 5 之后，讓 interval 停止值的發(fā)送。

最后的執(zhí)行效果：