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

観察可能な完了をマークすると、問題が発生しました。