bug修复
This commit is contained in:
@@ -40,7 +40,7 @@ function createWebSocket(token, onUpdate, onMessage) {
|
|||||||
console.log("WebSocket 已关闭", result);
|
console.log("WebSocket 已关闭", result);
|
||||||
onUpdate(false);
|
onUpdate(false);
|
||||||
stopHeartbeat();
|
stopHeartbeat();
|
||||||
reconnect(onMessage);
|
reconnect(onUpdate, onMessage);
|
||||||
});
|
});
|
||||||
|
|
||||||
// 启动心跳
|
// 启动心跳
|
||||||
@@ -50,7 +50,7 @@ function createWebSocket(token, onUpdate, onMessage) {
|
|||||||
/**
|
/**
|
||||||
* 重连机制
|
* 重连机制
|
||||||
*/
|
*/
|
||||||
function reconnect(onMessage) {
|
function reconnect(onUpdate, onMessage) {
|
||||||
if (reconnectCount >= RECONNECT_CONFIG.MAX_COUNT) return;
|
if (reconnectCount >= RECONNECT_CONFIG.MAX_COUNT) return;
|
||||||
|
|
||||||
reconnectTimer && clearTimeout(reconnectTimer);
|
reconnectTimer && clearTimeout(reconnectTimer);
|
||||||
@@ -64,7 +64,7 @@ function reconnect(onMessage) {
|
|||||||
);
|
);
|
||||||
reconnectTimer = setTimeout(() => {
|
reconnectTimer = setTimeout(() => {
|
||||||
console.log("reconnecting...");
|
console.log("reconnecting...");
|
||||||
createWebSocket(token, onMessage);
|
createWebSocket(token, onUpdate, onMessage);
|
||||||
reconnectCount++;
|
reconnectCount++;
|
||||||
}, delay);
|
}, delay);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user