subscriber更正
This commit is contained in:
parent
d3b456e495
commit
52c3c86c4f
|
|
@ -120,7 +120,7 @@ export class SubScriber extends Feature {
|
|||
socket.on('connect_error', async (err) => {
|
||||
this.count++;
|
||||
socket.removeAllListeners();
|
||||
// socket.disconnect();
|
||||
socket.disconnect();
|
||||
if (this.count > 50) {
|
||||
// 可能socket地址改变了,刷新重连
|
||||
this.url = undefined;
|
||||
|
|
|
|||
|
|
@ -124,7 +124,7 @@ class SubScriber extends Feature_1.Feature {
|
|||
socket.on('connect_error', async (err) => {
|
||||
this.count++;
|
||||
socket.removeAllListeners();
|
||||
// socket.disconnect();
|
||||
socket.disconnect();
|
||||
if (this.count > 50) {
|
||||
// 可能socket地址改变了,刷新重连
|
||||
this.url = undefined;
|
||||
|
|
|
|||
|
|
@ -158,7 +158,7 @@ export class SubScriber<ED extends EntityDict & BaseEntityDict> extends Feature
|
|||
socket.on('connect_error', async (err) => {
|
||||
this.count++;
|
||||
socket.removeAllListeners();
|
||||
// socket.disconnect();
|
||||
socket.disconnect();
|
||||
if (this.count > 50) {
|
||||
// 可能socket地址改变了,刷新重连
|
||||
this.url = undefined;
|
||||
|
|
|
|||
Loading…
Reference in New Issue