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

rxjs-7_retry-resetOnSuccess.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({ count: 2, resetOnSuccess: true })
  )
  .subscribe({ next: console.log, error: console.warn });
// (synchronously) 1, 2, 3, ERROR