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

rxjs-7_timeout.ts

import { timer } from "rxjs";
import { timeout } from "rxjs/operators";

const count$ = timer(3000, 2000);

count$
  .pipe(timeout({ first: 5000, each: 1000 }))
  .subscribe({ next: console.log, error: console.error });
// (after ~3s) 0
// (after ~1s) Error: Timeout has occurred