嵌套的 observables 订阅

Question

我有以下代码：

getUsers() {
    this.af.database.list(DB_URL)
    .map((users) => {
      return users.map((user) => {
        user.data = this.af.database.object(DB_URL_2).take(1);
        return user;
      });
    })
    .take(1)
    .subscribe((itemPrefs) => {
      this.users = users;
    })
  }

返回users 数组，其中user.data 是可观察的（用户信息）。

如何将user 的数据作为对象而不是作为可观察对象返回？我尝试订阅我的user.data，但它仍然返回 observable：

return users.map((user) => {
            user.data = this.af.database.object(DB_URL_2).take(1)
.subscribe((data) => {
return data;
});
        return user;
      });

Answer 1

我认为selectMany 应该可以解决问题，selectMany(RxJS4) mergeMap(RxJS 5) 的每个内部函数都会返回 observable，这将变平。这意味着它将确保所有内部data 都将变平。

代码

getUsers() {
    this.af.database.list(DB_URL)
    .mergeMap((user, i) => {
        return this.af.database.object(DB_URL_2).take(1).map(data => {
           user.data = data;
           return user;
        });
      });
    })
    .take(1)
    .subscribe((itemPrefs) => {
      this.users = users;
    })
}