订阅Angular 2中的多个Observable

Question

我的Angular 2应用程序在服务中有2个方法[GetCategories()和GetCartItems()],这两个方法都返回Observables.

为了从我的组件一个接一个地调用这两个方法,我写了下面的代码

 ngOnInit() 
{
   this.appService.GetCategories().subscribe( (data) => {
       this.appService.categories = data;


       this.appService.GetCartItems().subscribe( {
                                                    next: (data) => { this.appService.cart = data},
                                                    error: (err) => { this.toaster.error('cart==>' + err)}

                                                })

   });       
}

基本上从GetCategories()的订阅中调用GetCartItems,我觉得这不是正确的方法,这是一种回调地狱.

知道如何以更好的方式实现这一点(比如在promises中链接"then")？

Answer 1

看起来GetCartItems不依赖GetCategories.然后你可以使用zip:

Observable
    .zip(
        this.appService.GetCategories()
        this.appService.GetCartItems()
    )
    .catch(err => this.toaster.error(err))
    .subscribe(([categories, cartItems]) => {
        this.appService.categories = categories;
        this.appService.cart = cartItems;
    });

Answer 2

这通常是根据您的使用情况完成的concat(),concatMap()或者最终concatAll()取决于您是否需要按顺序调用这两种服务.

function GetCategories() {
    return Observable.timer(1000).do(() => console.log('GetCategories()'));
}

function GetCartItems() {
    return Observable.timer(1000).do(() => console.log('GetCartItems()'));
}

console.log('start...');

GetCategories()
  .concatMap(() => GetCartItems())
  .subscribe(() => console.log('done'));

这打印到控制台:

start...
GetCategories()
GetCartItems()
done

每个项目都会延迟显示,这些项目将按顺序逐个调用.

如果您不需要保持相同的订单,则可以使用merge()或mergeMap().

观看现场演示:https://jsbin.com/wawajob/1/edit

请注意,使用zip()可能会产生不良行为.请参阅https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/zip.md