()
| 260 | } |
| 261 | |
| 262 | private onClientClose() { |
| 263 | this.alive = false |
| 264 | this.subscriptions.clear() |
| 265 | this.authenticatedPubkeys.clear() |
| 266 | |
| 267 | const handlers = abortableMessageHandlers.get(this.client) |
| 268 | if (Array.isArray(handlers) && handlers.length) { |
| 269 | for (const handler of handlers) { |
| 270 | try { |
| 271 | handler.abort() |
| 272 | } catch (error) { |
| 273 | logger.error('Unable to abort message handler', error) |
| 274 | } |
| 275 | } |
| 276 | } |
| 277 | |
| 278 | this.removeAllListeners() |
| 279 | this.client.removeAllListeners() |
| 280 | } |
| 281 | } |