[What's New in RxJS 7] RxJS 6 retry #blog #rxjs

rxjs-6_retry.ts

import { defer, from } from "rxjs";
import { retry, tap } from "rxjs/operators";

const values = ["_", 0, 1, 0, 2, 0, 3, 0, 0, 0, 4];

defer(() => {
  values.shift();
  return from(values);
})
  .pipe(
    tap(i => {
      if (!i) throw "ERROR";
    }),
    retry(2)
  )
  .subscribe({ next: console.log, error: console.warn });
// (synchronously) 1, ERROR