From 46768e4cddef6f1b64ef52d3ba2213423abc91ab Mon Sep 17 00:00:00 2001 From: MiaoWoo Date: Tue, 26 May 2020 18:48:46 +0800 Subject: [PATCH] feat: modify ws on Message params Signed-off-by: MiaoWoo --- packages/websocket/src/tomcat/server.ts | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/packages/websocket/src/tomcat/server.ts b/packages/websocket/src/tomcat/server.ts index 64bb896e..06b9b9e0 100644 --- a/packages/websocket/src/tomcat/server.ts +++ b/packages/websocket/src/tomcat/server.ts @@ -31,15 +31,13 @@ class TomcatWebSocketServer extends EventEmitter { this.allClients[tomcatClient.id] = tomcatClient this.emit(ServerEvent.connect, tomcatClient) }, - onMessage: (message: any, session: TomcatWebSocketSession) => { - this.executor.execute(() => { - this.emit(ServerEvent.message, this.allClients[session.getId()], message) - }) + onMessage: (session: TomcatWebSocketSession, message: string) => { + this.executor.execute(() => this.emit(ServerEvent.message, this.allClients[session.getId()], message)) }, onClose: (session: TomcatWebSocketSession, reason: any) => { this.emit(ServerEvent.disconnect, this.allClients[session.getId()], reason) }, - onError: (session: TomcatWebSocketSession, error: any) => { + onError: (session: TomcatWebSocketSession, error: Error) => { this.emit(ServerEvent.error, this.allClients[session.getId()], error) }, })