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

解决 subscriber emit sub回调未进入

This commit is contained in:
wkj 2024-10-23 14:45:01 +08:00
parent 5cba70b566
commit a88490f9d1
3 changed files with 47 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
es/features/subscriber.js
View File

@ -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 () => {

28
lib/features/subscriber.js
View File

@ -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 () => {

29
src/features/subscriber.ts
View File

@ -226,19 +226,22 @@ export class SubScriber<ED extends EntityDict & BaseEntityDict> 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);
}
);
}