Oak-Team
/
oak-frontend-base
13
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 37 Wiki Activity

Merge branch 'dev' of gitea.51mars.com:Oak-Team/oak-frontend-base into dev

This commit is contained in:
Xu Chang 2024-08-30 14:22:36 +08:00
parent f28a55ec88 6a44707dc4
commit 4b766cccc7
4 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
es/features/subscriber.js
View File

@ -107,14 +107,15 @@ export class SubScriber extends Feature {
let count = 0;
socket.on('connect_error', async () => {
count++;
if (count > 10) {
if (count > 50) {
// 可能socket地址改变了，刷新重连
socket.removeAllListeners();
socket.disconnect();
this.url = undefined;
await this.connect();
resolve(undefined);
}
socket.removeAllListeners();
socket.disconnect();
this.socket = null;
await this.connect();
resolve(undefined);
});
}
socket.connect();

11
lib/features/subscriber.js
View File

@ -111,14 +111,15 @@ class SubScriber extends Feature_1.Feature {
let count = 0;
socket.on('connect_error', async () => {
count++;
if (count > 10) {
if (count > 50) {
// 可能socket地址改变了，刷新重连
socket.removeAllListeners();
socket.disconnect();
this.url = undefined;
await this.connect();
resolve(undefined);
}
socket.removeAllListeners();
socket.disconnect();
this.socket = null;
await this.connect();
resolve(undefined);
});
}
socket.connect();

2
package.json
View File

@ -1,6 +1,6 @@
{
"name": "oak-frontend-base",
"version": "5.3.4",
"version": "5.3.5",
"description": "oak框架中前端与业务逻辑无关的平台部分",
"author": {
"name": "XuChang"

13
src/features/subscriber.ts
View File

@ -148,16 +148,17 @@ export class SubScriber<ED extends EntityDict & BaseEntityDict> extends Feature
if (!optionInited) {
let count = 0;
socket.on('connect_error', async () => {
socket.on('connect_error', async (err) => {
count++;
if (count > 10) {
if (count > 50) {
// 可能socket地址改变了，刷新重连
socket.removeAllListeners();
socket.disconnect();
this.url = undefined;
await this.connect();
resolve(undefined);
}
socket.removeAllListeners();
socket.disconnect();
this.url = undefined;
await this.connect();
resolve(undefined);
});
}