Skip to content

Commit a3fc429

Browse files
author
Alex Lohr
committed
websocket: fix heartbeat after reconnect
1 parent 3fcb66b commit a3fc429

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

.changeset/eighty-sheep-travel.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"@solid-primitives/websocket": minor
3+
---
4+
5+
bugfix: setup heartbeat after reconnect

packages/websocket/src/index.ts

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -195,12 +195,13 @@ export const makeHeartbeatWS = (
195195
clearTimers();
196196
pongtimer = setTimeout(ws.reconnect, options.wait || 1500);
197197
};
198-
ws.addEventListener("close", clearTimers);
199198
const receiveMessage = () => {
200199
clearTimers();
201200
pingtimer = setTimeout(() => ws.send(options.message || "ping"), options.interval || 1000);
202201
};
202+
ws.addEventListener("close", clearTimers);
203203
ws.addEventListener("message", receiveMessage);
204-
setTimeout(receiveMessage, options.interval || 1000);
204+
ws.addEventListener("open", () => setTimeout(receiveMessage, options.interval || 1000));
205205
return ws;
206206
};
207+

0 commit comments

Comments
 (0)