Step 7.18: Subscribe to 'messages'

Urigo · Nov 27, 2016 · b983ca4 · b983ca4
1 parent 5489fed
commit b983ca4
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/client/imports/pages/chat/messages-page.component.ts b/client/imports/pages/chat/messages-page.component.ts
@@ -37,15 +37,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(() => {