Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private _chatObserver: Observable<firebase.database.DataSnapshot>
- otherMethod () {
- this._chatObserver = this._chat.observe(alarmId)
- this._chatObserver.subscribe(
- (messageSnap: firebase.database.DataSnapshot) => {
- this.messages.push(messageSnap.val())
- },
- error => {throw error})
- }
- ionViewDidLeave() {
- this._chatObserver.unsubscribe()
- }
- public observe (alarmId){
- let messagesRef = this._ref.child(`alarms/${alarmId}/messages`)
- const observable = Observable.create(observer => {
- messagesRef.on('child_added',(messageSnap) => {
- observer.next(messageSnap)
- },
- (error) => observer.error(error)
- )
- return () => {
- messagesRef.off('value')
- };
- });
- return observable
- }
Add Comment
Please, Sign In to add comment