()
| 192 | } |
| 193 | |
| 194 | public async dispose() { |
| 195 | const closeEventSignals = Array.from(this.httpServersRegistry) |
| 196 | .filter(([port]) => port !== UNDERLYING_HTTP_SERVER_PORT) |
| 197 | .map(([_, server]) => new Promise(resolve => server.close(resolve))); |
| 198 | |
| 199 | await Promise.all(closeEventSignals); |
| 200 | this.httpServersRegistry.clear(); |
| 201 | this.wsServersRegistry.clear(); |
| 202 | } |
| 203 | |
| 204 | public setMessageParser(parser: WsMessageParser) { |
| 205 | this.messageParser = parser; |