如何从 firebase firebase 函数返回 Observables

Question

我已经完美地运行了我的应用程序

"@angular/fire": "^6.1.5",
“火力基地”：“^8.6.3”，

就像

服务.ts

getUserEventSummary(userId) {
this.firestore.collection(`/user/${userId}/event_summary`).doc('current').snapshotChanges().pipe(
      map(changes => changes.payload.data())
    );
}

组件.ts

this.service.getUserEventSummary(this.userId).subscribe((res: any) => {
    this.values = res;
}

这样的代码遍布整个应用程序。 现在我已经转移到最新版本的 firebase

"firebase": "^9.0.1", "@angular/fire": "^7.0.4",

新的变化是

service.ts

getUserEventSummary(userId) {
 return getDoc(doc(db, `user/${userId}/event_summary`, 'current'));
}

还有组件.ts

this.service.getUserEventSummary(this.userId).subscribe((docSnap: any) => {
   if (docSnap.exists()) {
        this.values = docSnap.data();;
    }
 }

我需要一个返回相同行为的方法，即该代码返回承诺的可观察对象。

此外，快照更改很难在服务文件上实现。 请帮助我找到比更改组件代码更好的方法。

Answer 1

如果您在服务方法内部进行过滤和映射，那么您应该能够保持组件代码不变。你应该在你的服务中这样做：

import { /* ... */, from } from 'rxjs';

getUserEventSummary(userId) {
  return from(getDoc(doc(db, `user/${userId}/event_summary`, 'current'))).pipe(
    filter((docSnap) => docSnap.exists()),
    map(docSnap => docSnap.data())
  );
}

您可以使用 from 从该 Promise 对象创建一个 observable。