From e3d16c40354e75286eaf1a4ced79f4597330f657 Mon Sep 17 00:00:00 2001
From: Dotan Simha <dotansimha@gmail.com>
Date: Thu, 3 Nov 2016 21:08:36 +0200
Subject: [PATCH] Step 7.18: Subscribe to 'messages'

---
 src/pages/messages/messages.ts | 20 ++++++++++++--------
 1 file changed, 12 insertions(+), 8 deletions(-)

diff --git a/src/pages/messages/messages.ts b/src/pages/messages/messages.ts
index 58b71dc8a..4bab9c2d0 100644
--- a/src/pages/messages/messages.ts
+++ b/src/pages/messages/messages.ts
@@ -66,15 +66,19 @@ export class MessagesPage implements OnInit, OnDestroy {
   }
 
   ngOnInit() {
-    this.messages = Messages.find(
-      {chatId: this.selectedChat._id},
-      {sort: {createdAt: 1}}
-    ).map((messages: Message[]) => {
-      messages.forEach((message: Message) => {
-        message.ownership = this.senderId == message.senderId ? 'mine' : 'other';
+    MeteorObservable.subscribe('messages', this.selectedChat._id).subscribe(() => {
+      MeteorObservable.autorun().subscribe(() => {
+        this.messages = Messages.find(
+          {chatId: this.selectedChat._id},
+          {sort: {createdAt: 1}}
+        ).map((messages: Message[]) => {
+          messages.forEach((message: Message) => {
+            message.ownership = this.senderId == message.senderId ? 'mine' : 'other';
+          });
+
+          return messages;
+        });
       });
-
-      return messages;
     });
 
     this.autoScroller = MeteorObservable.autorun().subscribe(() => {