Weiba's Blog
0%

Angular中在Rxjs中并行处理多个Observable

发表于 更新于 分类于

15.Rxjs中并行处理多个Observable

1. forkJoin

1
2
3
4
5
6
7
let o1 = new Observable();
let o2 = new Observable();
let o3 = new Observable();

forkJoin([o1,o2,o3]).subscribe([r1,r2,r3]=>{
    ...
})

forkJoin:当每个Observable都完成时,才会触发subscribe方法,即每个Observable对象内,都需要有observer.complete()

2. combineLatest

1
2
3
4
5
6
7
8
let o1 = new Observable();
let o2 = new Observable();
let o3 = new Observable();

combineLatest([o1,o2,o3]).subscribe([r1,r2,r3]=>{
    ...
})

combineLatest:第一次,需要所有Observable都有返回值,后面只要某一个监听的Observable,返回值有更新,都会触发subscribe方法