From b983ca437f674ecac393cfe41e97a6d3292c6296 Mon Sep 17 00:00:00 2001
From: Kamil Kisiela <kamil.kisiela@gmail.com>
Date: Tue, 11 Oct 2016 10:14:02 +0200
Subject: [PATCH] Step 7.18: Subscribe to 'messages'

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

diff --git a/client/imports/pages/chat/messages-page.component.ts b/client/imports/pages/chat/messages-page.component.ts
index 4b4a9f9..ab2c6bc 100644
--- 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(() => {