diff --git a/es/features/subscriber.js b/es/features/subscriber.js index bfd914ec..6c014b68 100644 --- a/es/features/subscriber.js +++ b/es/features/subscriber.js @@ -183,19 +183,22 @@ export class SubScriber extends Feature { } else if (this.socketState === 'connected' && newEvents.length > 0) { await new Promise((resolve, reject) => { - this.socket.emit('sub', newEvents, (result) => { - if (result) { - this.message.setMessage({ - type: 'error', - title: 'sub data error', - content: result, - }); - reject(); - } - else { - resolve(undefined); - } - }); + // this.socket.emit('sub', newEvents, (result) => { + // if (result) { + // this.message.setMessage({ + // type: 'error', + // title: 'sub data error', + // content: result, + // }); + // reject(); + // } + // else { + // resolve(undefined); + // } + // }); + // TODO 临时代码 后续结合文档再解决 + this.socket.emit('sub', newEvents); + resolve(undefined); }); } return () => { diff --git a/lib/features/subscriber.js b/lib/features/subscriber.js index 4db7061d..fb427912 100644 --- a/lib/features/subscriber.js +++ b/lib/features/subscriber.js @@ -187,19 +187,21 @@ class SubScriber extends Feature_1.Feature { } else if (this.socketState === 'connected' && newEvents.length > 0) { await new Promise((resolve, reject) => { - this.socket.emit('sub', newEvents, (result) => { - if (result) { - this.message.setMessage({ - type: 'error', - title: 'sub data error', - content: result, - }); - reject(); - } - else { - resolve(undefined); - } - }); + // this.socket.emit('sub', newEvents, (result) => { + // if (result) { + // this.message.setMessage({ + // type: 'error', + // title: 'sub data error', + // content: result, + // }); + // reject(); + // } + // else { + // resolve(undefined); + // } + // }); + this.socket.emit('sub', newEvents); + resolve(undefined); }); } return () => { diff --git a/src/features/subscriber.ts b/src/features/subscriber.ts index 36863273..c638a76e 100644 --- a/src/features/subscriber.ts +++ b/src/features/subscriber.ts @@ -226,19 +226,22 @@ export class SubScriber extends Feature else if (this.socketState === 'connected' && newEvents.length > 0) { await new Promise( (resolve, reject) => { - this.socket!.emit('sub', newEvents, (result: string) => { - if (result) { - this.message.setMessage({ - type: 'error', - title: 'sub data error', - content: result, - }); - reject(); - } - else { - resolve(undefined); - } - }); + // this.socket!.emit('sub', newEvents, (result: string) => { + // if (result) { + // this.message.setMessage({ + // type: 'error', + // title: 'sub data error', + // content: result, + // }); + // reject(); + // } + // else { + // resolve(undefined); + // } + // }); + // TODO 临时代码 后续结合文档再解决 + this.socket!.emit('sub', newEvents); + resolve(undefined); } ); }