RxJS takeUntil

發(fā)出由源 Observable 發(fā)出的值，直到notifier Observable 發(fā)出值為止。

takeUntil<T>(notifier: Observable<any>): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：一個 Observable，它從源 Observable 發(fā)出值，直到notifier發(fā)出其第一個值為止。

描述

讓值傳遞，直到第二個 Observablenotifier發(fā)出值為止 。然后，它完成。

takeUntil訂閱并開始鏡像源 Observable。它還監(jiān)視notifier您提供的第二個 Observable 。如果notifier 發(fā)出值，則輸出 Observable 停止鏡像源 Observable 并完成。如果notifier不會發(fā)出任何值并完成，takeUntil則將傳遞所有值。

例

每秒打一次，直到第一次點擊發(fā)生

import { fromEvent, interval } from 'rxjs';
import { takeUntil } from 'rxjs/operators';


const source = interval(1000);
const clicks = fromEvent(document, 'click');
const result = source.pipe(takeUntil(clicks));
result.subscribe(x => console.log(x));

也可以看看

• take
• [takeLast_blank]()_blank](http://o2fo.com/rxjs/rxjs-7l4e3ck3.html)
• takeWhile
• skip