使用 rxjs 以角度连续调用 api

Question

假设我有 3 个在 app.component 中调用的服务，每个服务 subscribe() 在自己的服务中，那么我怎样才能得到一个一个响应。

app.component.ts

ngOnInit() {
  this._salesstageService.refreshSalesstage();
  this._opportunityMailsService.RefreshTop50();
  this._opportunityService.getOpportunities();
}

例如，我有三个 service.ts 文件，但在这里您可以看到一个调用 api 的服务函数。

app.service.ts

   getOpportunities() {
       return this.http.get(this._opportunitiesUrl)
        .do(res => this._errorService.checkResponse(res))
        .map(res => <Opportunity[]>JSON.parse(res.text(), 
              this.opportunityReviver))
        .catch(err => this._errorService.handleError<Opportunity[]>(err))
        .subscribe(
          opportunities => {
            if(opportunities instanceof Array){
                this._opportunities = opportunities;
               this.opportunities$.next(this._opportunities);
            }
        })
    } 

Answer 1

由于您的服务似乎发布了 observable，因此以嵌套方式订阅它们。

this._salesstageService.salesstage$.subscribe(() => {
  this._opportunityMailsService.RefreshTop50();
  this._opportunityMailsService.mail$.subscribe(() => this._opportunityService.getOpportunities());
});

this._salesstageService.refreshSalesstage();