concatAll:有时 Observable 发出的又是一个 Obervable,concatAll 的作用就是将新的可观察对象和数据源进行合并

  1. import { fromEvent, interval } from "rxjs"
  2. import { map, take, concatAll } from "rxjs/operators"
  3. fromEvent(document, "click")
  4. .pipe(
  5. map(event => interval(1000).pipe(take(2))),
  6. concatAll()
  7. )
  8. .subscribe(console.log)
  1. import { map, concatAll } from "rxjs/operators"
  2. import { of, interval } from "rxjs"
  3. interval(1000)
  4. .pipe(
  5. map(val => of(val + 10)),
  6. concatAll()
  7. )
  8. .subscribe(console.log)

29.png

concatMap:合并可观察对象并处理其发出的数据流

30.png