forkJoin替代未完成的observable？

Question

constructor(
    private route: ActivatedRoute,
    private http: Http
){
    // Observe parameter changes
    let paramObs = route.paramMap;

    // Fetch data once
    let dataObs = http.get('...');

    // Subscribe to both observables,
    // use both resolved values at the same level
}

forkJoin每当发出参数更改时,是否存在类似于触发器的内容？forkJoin仅在所有可观测量完成后才有效.

我只需要避免回调地狱,任何符合的选择都是受欢迎的.

Answer 1

有几种选择:

1. 使用take(1)与forkJoin()完成每个源可观察到:

   forkJoin(o1$.take(1), o2$.take(1))
   

2. 仅当所有源Observable发出相同数量的项时,才使用zip()和take(1)发出:

   zip(o1$, o2$).take(1)
   

3. 用于combineLatest()在任何源Observable发出时发出:

   combineLatest(o1$, o2$)
   

2019年1月:更新了RxJS 6