From 55b07ca3ab6229140df287a4fc06b68c37901b38 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Tue, 17 Sep 2024 09:23:19 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=BD=BB=E5=BA=95=E7=A7=BB=E9=99=A4eve?= =?UTF-8?q?nt=E6=97=A7=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/common/event.ts | 79 --------------------------------------------- 1 file changed, 79 deletions(-) diff --git a/src/common/event.ts b/src/common/event.ts index 00fc3e37..3fa5fe8a 100644 --- a/src/common/event.ts +++ b/src/common/event.ts @@ -254,83 +254,4 @@ export class NTEventWrapper { }, ); } - - /* - async callNormalEvent< - Service extends keyof ServiceNamingMapping, - ServiceMethod extends Exclude, - Listener extends keyof ListenerNamingMapping, - ListenerMethod extends Exclude, - // eslint-disable-next-line - // @ts-ignore - EventType extends (...args: any) => any = ServiceNamingMapping[Service][ServiceMethod], - // eslint-disable-next-line - // @ts-ignore - ListenerType extends (...args: any) => any = ListenerNamingMapping[Listener][ListenerMethod] - >( - serviceAndMethod: `${Service}/${ServiceMethod}`, - listenerAndMethod: `${Listener}/${ListenerMethod}`, - waitTimes = 1, - timeout: number = 3000, - checker: (...args: Parameters) => boolean, - ...args: Parameters - ) { - return new Promise<[EventRet: Awaited>, ...Parameters]>( - async (resolve, reject) => { - const id = randomUUID(); - let complete = 0; - let retData: Parameters | undefined = undefined; - let retEvent: any = {}; - const databack = () => { - if (complete == 0) { - reject( - new Error( - 'Timeout: NTEvent EventName:' + - serviceAndMethod + - ' ListenerName:' + - listenerAndMethod + - ' EventRet:\n' + - JSON.stringify(retEvent, null, 4) + - '\n', - ), - ); - } else { - resolve([retEvent as Awaited>, ...retData!]); - } - }; - - const ListenerNameList = listenerAndMethod.split('/'); - const ListenerMainName = ListenerNameList[0]; - const ListenerSubName = ListenerNameList[1]; - - const Timeouter = setTimeout(databack, timeout); - - const eventCallbak = { - timeout: timeout, - createtime: Date.now(), - checker: checker, - func: (...args: any[]) => { - complete++; - //console.log('func', ...args); - retData = args as Parameters; - if (complete >= waitTimes) { - clearTimeout(Timeouter); - databack(); - } - }, - }; - if (!this.EventTask.get(ListenerMainName)) { - this.EventTask.set(ListenerMainName, new Map()); - } - if (!this.EventTask.get(ListenerMainName)?.get(ListenerSubName)) { - this.EventTask.get(ListenerMainName)?.set(ListenerSubName, new Map()); - } - this.EventTask.get(ListenerMainName)?.get(ListenerSubName)?.set(id, eventCallbak); - this.createListenerFunction(ListenerMainName); - const EventFunc = this.createEventFunction(serviceAndMethod); - retEvent = await EventFunc!(...(args as any[])); - }, - ); - } - */ }