Step 7.18: Subscribe to 'messages'

Urigo · Nov 28, 2016 · e3d16c4 · e3d16c4
1 parent 9aace5d
commit e3d16c4
Showing 1 changed file with 12 additions and 8 deletions.
diff --git 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(() => {