RxJS repeatWhen

返回一個(gè) Observable，它鏡像源 Observable，但除外complete。如果源 Observable 調(diào)用complete，則此方法將向發(fā)出返回給 Observable 的方法notifier。如果該 Observable 調(diào)用complete或error，則此方法將在子訂閱上調(diào)用complete或error。否則，此方法將重新訂閱源 Observable。

repeatWhen<T>(notifier: (notifications:Observable<any>) => Observable<any>): MonoTypeOperatorFunction<T>

參量

returns

MonoTypeOperatorFunction<T>：使用重復(fù)邏輯修改了源 Observable。

描述

例

重復(fù)點(diǎn)擊消息流

import { of, fromEvent } from 'rxjs';
import { repeatWhen } from 'rxjs/operators';


const source = of('Repeat message');
const documentClick$ = fromEvent(document, 'click');


source.pipe(repeatWhen(() => documentClick$)
).subscribe(data => console.log(data))

也可以看看

• repeat
• retry
• retryWhen