import { repeatWhen } from "https://deno.land/x/rxjs@v1.0.2/mod.ts";
Returns 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))
Parameters
notifier: (notifications: Observable<void>) => Observable<any>
- Receives an Observable of notifications with
which a user can
complete
orerror
, aborting the repetition.