Function genericRetryStrategy

packages/zone.js/test/rxjs/rxjs.retry.spec.ts:13–24

(finalizer: () => void)

describe('retryWhen', () => {
  let log: any[];
  const genericRetryStrategy = (finalizer: () => void) => (attempts: Observable<any>) =>
    attempts.pipe(
      mergeMap((error, i) => {
        const retryAttempt = i + 1;
        if (retryAttempt > 3) {
          return throwError(error);
        }
        log.push(error);
        return timer(retryAttempt * 1);
      }),
      finalize(() => finalizer()),
    );

  const errorGenerator = () => {
    return throwError(new Error('error emit'));