带有 rxjs 的异步管道

【问题标题】：Async pipe with rxjs带有 rxjs 的异步管道
【发布时间】：2019-12-23 06:05:50
【问题描述】：

我在异步管道中有一个小问题这是我的情况，我需要在 html 的异步管道中运行嵌套的 observables，因为我使用推送策略并且我不想使用一些变通方法或更改检测器参考。我的问题是，当我运行下面的代码时，只调用了第一个 observable 我应该添加返回语句吗？或者是什么问题？

Ts 代码

this.http.getUsers(criteria)
.pipe(map(data=>{
data.users.map(user=>{
this.http.getUserData(user.id)
.pipe(map(res=>{user.data=res.data}))}}

HTML代码

<div *ngFor=let user of users$ | async> </div>

【问题讨论】：

【解决方案1】：

你想做一个 switchMap，你需要为 users$ 属性分配一个 observable。

users$ = this.http.getUsers(criteria).pipe(
  switchMap(user => this.http.getUserData(user.id)),
  map(res => res.data)
);

【讨论】：