expose PrimaryKeepaliveMessage endLsn back #30

kagis · May 26, 2023 · 9532a39 · 9532a39
1 parent 6545bc4
commit 9532a39
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mod.js b/mod.js
@@ -1597,10 +1597,11 @@ class ReplicationStream extends BinaryReader {
               break;
             case 'PrimaryKeepaliveMessage':
               shouldAck = shouldAck || msg.shouldReply;
-              // TODO msg.endLsn not exposed
+              // TODO messages.push(msg); ?
               break;
           }
           if (lastLsn < msg.lsn) lastLsn = msg.lsn;
+          if (lastLsn < msg.endLsn) lastLsn = msg.endLsn;
           if (lastTime < msg.time) lastTime = msg.time;
         }
         if (shouldAck) {