观察更改打字稿的firebase数据库

Question

所以我在这样的角度服务中调用我的 firebase 实时数据库：

readItems() {
    return this.af.database.ref(`/path`)
      .on('value', snap => this.callback(snap.val()));
  }

回调只是根据我的需要修改响应。我需要做的是在我调用readItems 的组件中获取修改后的数据。这是所述组件中的调用：

this.service.readItems();

我想知道何时完成并使用带有subscribe 或then 的可观察或承诺返回修改后的响应。我不知道如何做到这一点，任何帮助都会很棒。

Answer 1

您可以在传递给on 函数的回调中使用来自 rxjs 的 Subject 并订阅它：

valueChanged$ = new Subject();

callback(val) {
    // some code ...
    valueChanged$.next(val); // pass whatever you need to receive in the subscription
}

readItems() {
  return this.af.database.ref(`/path`)
    .on('value', snap => this.callback(snap.val()));
}

然后在您的代码中：

this.valueChanged$.subscribe(data => doStuff(data));
this.service.readItems();