使用 Observable 映射数组的 Observable

Question

我试图找到一种方法来让这个场景发挥作用：

• 我有一个可观察的talks$，它会发出所有谈话的列表。
• 谈话有属性personId
• 可以使用 Observable 将该属性映射到人员。
• 我尝试将它映射到一个类TalkWithPerson

const test = this.talks$.pipe(
  exhaustMap(talks =>
    talks.map(t => this.getPersonById(t.personId).pipe(map(p => newTalkWithPerson(t, p))))
  ),
);

目前，这会发出 2 个 observable，每个都发出我的 TalkWithPerson 对象。 (Observable<Observable<TalkWithPerson>>)

如果可能的话，我想拥有一个Observable<TalkWithPerson[]>。

我正在考虑让所有人和所有谈话都走得很艰难，并使用带有项目功能的combineLatest 来匹配记录，但我不想加载所有人，它会导致加载巨大的清单...

感谢您的帮助！

堆栈闪电战：https://stackblitz.com/edit/talks-person

Answer 1

试试这个：

const test = this.talks$.pipe(
    exhaustMap(talks =>
        from(talks)
            .pipe(
                mergeMap(t => this.getPersonById(t.personId).pipe(map(p => newTalkWithPerson(t, p)))),                  
                toArray())
            )
  ),
);

• 导入from作为创建方法import { from } from "rxjs";
• 导入 toArray 与 'map' 管道运算符相同

Answer 2

为此使用flatMap 运算符。 flatMap 将 Observable<Observable<TalkWithPerson[]>> 解包成 Observable<TalkWithPerson[]>

所以尝试这样做：

const test = this.talks$.pipe(
  exhaustMap(talks =>
    talks.flatMap(t => this.getPersonById(t.personId).pipe(map(p => newTalkWithPerson(t, p))))
  ),
);