angular - 如何使用 forkjoin 返回 Angular 中两个独立 API 调用的组合响应

Question

我有两个独立的 API 调用。下面是两个 api 调用的代码:

public getLendingType(partyId: string): Observable<{ lendingType: string, partyId: string }> {
    return this.customerRepositoryService.getCustomer(partyId).pipe(
        map((customer: ICustomer) => {
          return { lendingType: customer.LendingType, partyId: partyId } ;
        })
      );
  }

  private getPartyType(partyId: string): Observable<{ partyType: string}> {
    return this.partyRepositoryService.getParty(partyId).pipe(
      map((party: IParty) => {
        return  { partyType: party.PartyType };
      })
    );
  }

如您所见，这两个 api 调用是相互独立的。此时我想使用 forkjoin 来组合他们的响应并返回组合结果。这就是我卡住的地方。我为这部分编写的代码如下:

  public getPartyTypeAndLendingType(partyId: string): Observable<{ partyType: string, lendingType: string, partyId: string }> {

        return forkJoin([this.getLendingType(partyId), this.getPartyType(partyId)]).subscribe ( result => {
            return { partyType: result[1].partyType, lendingType: result[0].lendingType, partyId: result[0].partyId }
        })
  }

但我想我遗漏了一些东西，但我仍然遇到编译器错误，如下图所示:

并将鼠标悬停在它显示以下消息的编译器错误上:

Type 'Subscription' is missing the following properties from type 'Observable<{ partyType: string; lendingType: string; partyId: string; }>': source, operator, lift, subscribe, and 3 more.ts(2740

如何实现这一点并使这段代码工作？

Answer 1

因为您正在调用 .subscribe()，您的函数返回一个 Subscription 而不是 Observable。

要转换 API 调用的结果，请使用带有 map() 的 .pipe()。这样您的函数将返回一个 Observable。

return forkJoin([
    this.getLendingType(partyId), 
    this.getPartyType(partyId)
]).pipe(
  map(result => 
    ({ partyType: result[1].partyType, lendingType: result[0].lendingType, partyId: result[0].partyId })     
  )
)