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

rxjs-6_timeout.ts

import { concat, partition, timer } from "rxjs";
import { first, share, timeout } from "rxjs/operators";

const count$ = timer(3000, 2000).pipe(share());

const [first$, rest$] = partition(count$, (_, index) => index === 0);

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