13.5.13 - mergeAll、mergeMap

mergeAll：交叉合并可观察对象

import { fromEvent, interval } from "rxjs"
import { map, mergeAll } from "rxjs/operators"
fromEvent(document, "click")
  .pipe(
    map(() => interval(1000)),
    mergeAll()
  )
.subscribe(console.log)

mergeMap：交叉合并可观察对象以后对可观察对象发出的数据流进行转换

import { of, interval } from "rxjs"
import { mergeMap, map } from "rxjs/operators"
of("a", "b", "c")
  .pipe(mergeMap(x => interval(1000).pipe(map(i => x + i))))
  .subscribe(x => console.log(x))