如何使用forkjoin返回两个独立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（）您的功能返回sisscription而不是可观察的。

要转换API调用的结果，请使用.pipe（）使用map（）。这样，您的功能将返回可观察的。

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

Answer 2

您遇到了错误，因为在方法签名上，您说的是您将返回可观察的，但是您要返回的是subpcription。有一个简单的修复程序，但是您真的很接近:)，

public getPartyTypeAndLendingType(partyId: string): Observable<{ partyType: string, lendingType: string, partyId: string }> {
  const lendingType = this.getLendingType(partyId);
  const partyType = this.getPartyType(partyId);

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

而不是在该方法中订阅（这是对某些目的，实际上取决于您的需求），我们现在使用MAP运算符来映射反应。现在订阅部分应由呼叫者完成。