typescript - Firebase 和 RxJS

Question

我做了一个监听值事件的函数:

getUnreadMessages() : Observable<any>{
    return new Observable(observer =>{
      firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{

        let count = 0;
        ...some more logic here...

        observer.next(count);
        observer.complete();

      }, (error) =>{
        observer.error(error);
      })
    })
  }

当数据库发生变化时，我可以看到该函数已输入，但我在整个应用程序中订阅它的地方并没有触发。有什么建议吗？

Answer 1

将可观察对象标记为完成是问题的原因。