repeatWhen
deprecatedReturns an Observable that mirrors the source Observable with the exception of a complete
. If the source
Observable calls complete
, this method will emit to the Observable returned from notifier
. If that Observable
calls complete
or error
, then this method will call complete
or error
on the child subscription. Otherwise
this method will resubscribe to the source Observable.
Example
Repeat a message stream on click
import { of, fromEvent, repeatWhen } from 'rxjs';
const source = of('Repeat message');
const documentClick$ = fromEvent(document, 'click');
const result = source.pipe(repeatWhen(() => documentClick$));
result.subscribe(data => console.log(data))
@deprecated
Will be removed in v9 or v10. Use repeat's {@link RepeatConfig#delay | delay} option instead.
Instead of repeatWhen(() => notify$)
, use: repeat({ delay: () => notify$ })
.
function repeatWhen<T>(notifier: (notifications: Observable<void>) => ObservableInput<any>): MonoTypeOperatorFunction<T>;
§
repeatWhen<T>(notifier: (notifications: Observable<void>) => ObservableInput<any>): MonoTypeOperatorFunction<T>
[src]§Parameters
§
notifier: (notifications: Observable<void>) => ObservableInput<any>
[src]Function that receives an Observable of notifications with
which a user can complete
or error
, aborting the repetition.