Skip to content

Commit a5cd811

Browse files
louis.tianporsager
authored andcommitted
update lsn on Primary Keep Alive Message
1 parent 5404fbd commit a5cd811

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/subscribe.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,8 +110,10 @@ export default function Subscribe(postgres, options) {
110110
function data(x) {
111111
if (x[0] === 0x77)
112112
parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)
113-
else if (x[0] === 0x6b && x[17])
113+
else if (x[0] === 0x6b && x[17]) {
114+
state.lsn = x.subarray(1, 9)
114115
pong()
116+
}
115117
}
116118

117119
function handle(a, b) {

0 commit comments

Comments
 (0)