RxJS Subject 学习

Subject

其实一个 Observable 可以被订阅多次, 但是并不共享一个流的数据,如下例

1
2
3
4
5
6
let stream$ = Rx.of(1, 2, 3);
stream$.subscribe(r => console.log("a", r));

setTimeout(() => {
stream$.subscribe(r => console.log("b", r));
}, 110);

输出结果

1
2
3
4
5
6
a 1
a 2
a 3
b 1
b 2
b 3

RxJS 操作符笔记

RxJS 6

操作符

一些常用的操作符

  • of
  • from
  • first
  • last
  • tap
  • interval
  • timer
  • forkJoin
  • filter
  • map
  • switchMap
  • scan
  • takeWhile
  • takeUtil
  • take
  • concat
  • throttle
  • debounce
  • merge

of

将数字转化为 Observable

1
2
Rx.of("1", "2").subscribe(v => console.log(v));
// 输出 1, 2

JavsScript 函数式学习手记

高阶函数

  • map
  • filter
  • some
  • every
  • reduce
  • unary
  • once
  • pluck
  • pick
  • zip
  • flatten
  • merge
  • takeLast
  • uniq
  • omit
  • memoized
  • compose
  • pipe
  • debounce
  • throttle
Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×