Guest User

Untitled

a guest
Oct 24th, 2017
76
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.81 KB | None | 0 0
  1. private _chatObserver: Observable<firebase.database.DataSnapshot>
  2.  
  3. otherMethod () {
  4. this._chatObserver = this._chat.observe(alarmId)
  5. this._chatObserver.subscribe(
  6. (messageSnap: firebase.database.DataSnapshot) => {
  7. this.messages.push(messageSnap.val())
  8. },
  9. error => {throw error})
  10. }
  11.  
  12. ionViewDidLeave() {
  13. this._chatObserver.unsubscribe()
  14. }
  15.  
  16. public observe (alarmId){
  17. let messagesRef = this._ref.child(`alarms/${alarmId}/messages`)
  18.  
  19. const observable = Observable.create(observer => {
  20. messagesRef.on('child_added',(messageSnap) => {
  21. observer.next(messageSnap)
  22. },
  23. (error) => observer.error(error)
  24. )
  25. return () => {
  26. messagesRef.off('value')
  27. };
  28. });
  29.  
  30. return observable
  31. }
Add Comment
Please, Sign In to add comment