Firebase et RxJS

Question

j'ai fait une fonction qui écoute la valeur des événements:

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); 
     }) 
    }) 
    } 

Lorsque les modifications de la base, je peux voir que cette fonction est entrée, mais où je souscris tout au long de l'application ne se déclenche pas . Aucune suggestion? Le marquage de l'observable complet était la cause du problème.

Answer 1