circlecloud/ms
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

feat: modify ws on Message params

Browse Source 
Signed-off-by: MiaoWoo <admin@yumc.pw>
This commit is contained in:
MiaoWoo
2020-05-26 18:48:46 +08:00
parent 78fcbbe9a5
commit 95cd8c4889
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/websocket/src/tomcat/server.ts
View File

@@ -31,15 +31,13 @@ class TomcatWebSocketServer extends EventEmitter {
this.allClients[tomcatClient.id] = tomcatClient this.allClients[tomcatClient.id] = tomcatClient
this.emit(ServerEvent.connect, tomcatClient) this.emit(ServerEvent.connect, tomcatClient)
}, },
onMessage: (message: any, session: TomcatWebSocketSession) => { onMessage: (session: TomcatWebSocketSession, message: string) => {
this.executor.execute(() => { this.executor.execute(() => this.emit(ServerEvent.message, this.allClients[session.getId()], message))
this.emit(ServerEvent.message, this.allClients[session.getId()], message)
})
}, },
onClose: (session: TomcatWebSocketSession, reason: any) => { onClose: (session: TomcatWebSocketSession, reason: any) => {
this.emit(ServerEvent.disconnect, this.allClients[session.getId()], reason) 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) this.emit(ServerEvent.error, this.allClients[session.getId()], error)
}, },
}) })