如何组合多个嵌套的角度展平运算符？

Question

我正在尝试从多个函数中使用 Observables 的结果。有些需要按顺序运行，有些则不需要。另外，第一个的结果需要传递给一些嵌套的。

我查看了多个示例。但是，我似乎无法弄清楚这种特殊的组合。语法只是让我感到困惑。

假设您有以下函数，每个函数都返回一个 Observable。

saveContactDetails(): Observable<ContactDetails> {
    // Returns single observable with single ContactDetails.
}

savePhones(contactId: string): Observable<Phone[]> {
    // Returns single observable with array of Phones.
}

saveEmails(contactId: string): Observable<Email[]> {
    // Returns single observable with array of Emails.
}

saveAll(): Observable<Contact> {
    // TODO: Can't figure out the login/syntax here.
}

步骤：

1. 调用 saveContactDetails()。只有在这完成后，才能继续。
2. 使用 saveContactDetails() 的结果，调用 savePhones() 和 saveEmails()。这两个函数（可能还有更多函数）可以不按特定顺序并行运行。
3. 所有“子”Observable 完成后，将所有（父级和子级）的结果合并到一个 Observable 中以从 saveAll() 返回。

我假设我需要使用concatMap 和mergeMap（或者可能是forkJoin）。但同样，我似乎无法使用在线文档和示例弄清楚语法。

Answer 1

看起来像这样。

您将 switchMap 转换为需要从第一个输入的那些的 forkJoin。然后您使用内部地图来组合所有 3 的结果。

  saveAll(): Observable<Contact> {
    return this.saveContactDetails().pipe(
      switchMap(contactDetails => forkJoin([
          this.savePhones(contactDetails.id), // however you get the id
          this.saveEmails(contactDetails.id)
        ]).pipe(
          map(([phones, emails]) => 
            Object.assign(contactDetails, {phones, emails})) // whatever your transform is
        )
      )
    );
  }