TypeScript 嵌套的异步函数

Question

profile.page.ts:

  username: string;
  totalScore: number;
  ...


  loadUserData() {
    this.spinnerDialog.show();
    this.firebaseServie.loadUserData().then(() => {
      this.username = this.sessionData.getUser().getUsername();
      this.totalScore = this.sessionData.getUser().getTotalScore();
       ....
    });

firebase.service.ts:

async loadUserData() {
    console.log(this.sessionData.getUser().getEmail());
    this.userCollection = this.afs.collection('users', ref => ref.where('email', '==', this.sessionData.getUser().getEmail().toLowerCase()));

    this.userDoc = this.afs.collection("users").doc(this.sessionData.getUser().getEmail().toLowerCase());

    this.x = this.userDoc.valueChanges().subscribe(((item: User) => {
      this.userLoadedUser = item;
      console.log("Found user by email id " + this.sessionData.getUser().getEmail() + ":" + this.userLoadedUser.username);
      this.sessionData.getUser().setUsername(this.userLoadedUser.username);
      this.sessionData.getUser().setTotalScore(this.userLoadedUser.totalScore);
      ....

    }));
  }

那么我如何确定then() 子句中的部分只有在我们从firebase 获得数据后才执行？

我已经编辑了我的问题以便更好地理解。

Answer 1

您可以简单地在您的firebase.service.ts 中返回一个新的 Promise：

loadUserData() {
    return new Promise((resolve, reject) => {
        ...
        this.x = this.userDoc.valueChanges().subscribe(((item: User) => {
            ...
            resolve(); // If everything worked!
        }));
        ...
    });
}

希望对你有帮助！

Answer 2

由于 subscribe 表明你正在处理一个 observable，最好不要开始与 promise 混合，而只需使用 observable 和 pipe

otherfunc()
    .pipe(map(myfunc))
    .subscribe((item:User) => {

});

如果你真的想要 Promise，你可以将 observable 转换为 Promise。

otherfunc().toPromise().then(myfunc).then(e => {
    // runs after
});