map:对数据流进行转换,基于原有值进行转换

  1. import { interval } from "rxjs"
  2. import { map } from "rxjs/operators"
  3. interval(1000)
  4. .pipe(map(n => n * 2))
  5. .subscribe(n => console.log(n))

13.png

mapTo:对数据流进行转换,不关心原有值,可以直接传入要转换后的值

  1. import { interval } from "rxjs"
  2. import { mapTo } from "rxjs/operators"
  3. interval(1000)
  4. .pipe(mapTo({ msg: "接收到了数据流" }))
  5. .subscribe(msg => console.log(msg))

14.png