7.1 RXJS : Setup - quan1997ap/angular-app-note GitHub Wiki

1. Chuẩn bị môi trường

https://stackblitz.com/edit/rxjs-sxpywm?file=index.ts

import {
  of,
  map,
  Observable,
  combineLatest,
  interval,
  forkJoin,
  zip,
} from 'rxjs';

const observer = {
  next: (val) => console.log(val),
  error: (err) => console.log(err),
  complete: () => console.log('complete'),
};

// zip(of(1, 2, 3), of(4, 5, 6), of(7, 8, 9)).subscribe(observer);
combineLatest([
  interval(5000).pipe(
    map((x) => {
      console.log('First');
      return `First: ${x}`;
    })
  ), // {1}
  interval(1000).pipe(
    map((x) => {
      console.log('Second');
      return `Second: ${x}`;
    })
  ), // {2}
  interval(10000).pipe(
    map((x) => {
      console.log('Third');
      return `Third: ${x}`;
    })
  ), // {3}
]).subscribe(observer);