AngularFire2 firestore take(1) on doc valueChanges

Question

使用 AngularFire2 我尝试从单个 Firestore 文档中获取数据。 有效的是：

this.addressRef = afs.doc<Address>('addresses/key')
this.addressRef.valueChanges().subscribe(val => {......}

我只想运行一次订阅代码。通常我使用 take(1) 来实现这一点（与 Firebase DB 一起使用）。 但是这段代码：

this.addressRef.valueChanges().take(1).subscribe(val => {......}

给出错误：TypeError：this.addressRef.valueChanges(...).take 不是函数。

VS Code 正在列出执行操作。这是 AngularFire2 中的错误，我做错了还是有其他（更好的）方法可以在获取数据后停止订阅？我也尝试过 topromise，但这也失败了。

Answer 1

更新

因为这个答案受到了很多关注，所以我提供了一个更新的答案。通常，在使用可观察对象进行编程时，您应该尝试进行反应式思考。有一些很棒的教程，但是this one is 很好。

新解决方案

user$ = this.afDs.doc<User>('users/NaGjauNy3vYOzp759xsc')
  .valueChanges().pipe(
    take(1) // Here you can limit to only emit once, using the take operator
  )

在你的模板中，你订阅了你的 observable。

{{(user$ | async).name}}

上下文

这种解决问题的方法有很多好处：

• 如果您不想转换数据，则只需输入地图运算符
• 您可以使用 rxjs 过滤器操作符过滤事件
• 根据 user$ 流创建其他流
• 易于调试，因为其他开发人员可以以更透明的方式查看您应用中的数据流

例如（创建另一个流，仅在用户是管理员时发出，并创建一个新标题）：

adminTitle$ = this.user$.pipe(
  filter(user => user.title === 'admin'),
  map(user => `${user.name} (admin)`)
)

旧答案

您可以通过执行以下操作来实现此目的：

this.userDoc = afDs.doc<User>('users/NaGjauNy3vYOzp759xsc');
this.userDoc.valueChanges()
  .pipe(take(1))
  .subscribe(v => {
    this.user = v;
  });