fix for #124

src/views/messages-view.jsx

@@ -245,12 +245,17 @@ class MessagesView extends React.Component {
       this.postReadNotification(0);
     }
 
-    if (topic && ((this.state.topic != prevState.topic) || !prevProps.ready)) {
+    if (topic) {
-      // Don't immediately subscribe to a new p2p topic, wait for the first message.
+      if ((this.state.topic != prevState.topic) || !prevProps.ready) {
-      if (topic._new && topic.isP2PType()) {
+        // Don't immediately subscribe to a new p2p topic, wait for the first message.
-        topic.getMeta(topic.startMetaQuery().withDesc().build());
+        if (topic._new && topic.isP2PType()) {
-      } else {
+          topic.getMeta(topic.startMetaQuery().withDesc().build());
-        this.subscribe(topic);
+        } else {
+          this.subscribe(topic);
+        }
+      } else if (topic.isSubscribed() && this.state.isReader && !prevState.isReader) {
+        // If reader status has changed and data became available.
+        topic.getMeta(topic.startMetaQuery().withLaterData().build());
       }
     }
   }

umd/index.dev.js

@@ -5284,11 +5284,15 @@ class MessagesView extends (react__WEBPACK_IMPORTED_MODULE_0___default().Compone
     } else {
       this.postReadNotification(0);
     }
-    if (topic && (this.state.topic != prevState.topic || !prevProps.ready)) {
+    if (topic) {
-      if (topic._new && topic.isP2PType()) {
+      if (this.state.topic != prevState.topic || !prevProps.ready) {
-        topic.getMeta(topic.startMetaQuery().withDesc().build());
+        if (topic._new && topic.isP2PType()) {
-      } else {
+          topic.getMeta(topic.startMetaQuery().withDesc().build());
-        this.subscribe(topic);
+        } else {
+          this.subscribe(topic);
+        }
+      } else if (topic.isSubscribed() && this.state.isReader && !prevState.isReader) {
+        topic.getMeta(topic.startMetaQuery().withLaterData().build());
       }
     }
   }
@@ -16539,7 +16543,7 @@ function isVersionServiceProvider(provider) {
 }
 
 const name$o = "@firebase/app";
-const version$1 = "0.9.5";
+const version$1 = "0.9.7";
 
 /**
  * @license
@@ -16606,7 +16610,7 @@ const name$2 = "@firebase/firestore";
 const name$1 = "@firebase/firestore-compat";
 
 const name = "firebase";
-const version = "9.18.0";
+const version = "9.19.1";
 
 /**
  * @license
@@ -20543,7 +20547,7 @@ __webpack_require__.r(__webpack_exports__);
 
 
 var name = "firebase";
-var version = "9.18.0";
+var version = "9.19.1";
 
 /**
  * @license