将两个 Obserable 中最新发出的数据流进行组合成新的数据流,以数组的形式发出。和当前最新的进行组合

  1. import { combineLatest, timer } from "rxjs"
  2. const firstTimer = timer(0, 1000) // emit 0, 1, 2... after every second, starting from now
  3. const secondTimer = timer(500, 1000) // emit 0, 1, 2... after every second, starting 0,5s from now
  4. combineLatest(firstTimer, secondTimer).subscribe(console.log)
  5. // [0, 0] after 0.5s
  6. // [1, 0] after 1s
  7. // [1, 1] after 1.5s
  8. // [2, 1] after 2s

40.png