()
| 134 | } |
| 135 | |
| 136 | public onHeartbeat(): void { |
| 137 | if (!this.alive) { |
| 138 | logger.error(`web-socket-adapter: pong timeout for client ${this.clientId} (${this.getClientAddress()})`) |
| 139 | this.client.close() |
| 140 | return |
| 141 | } |
| 142 | |
| 143 | this.alive = false |
| 144 | this.client.ping() |
| 145 | debugHeartbeat('client %s ping', this.clientId) |
| 146 | } |
| 147 | |
| 148 | public getSubscriptions(): Map<string, SubscriptionFilter[]> { |
| 149 | return new Map(this.subscriptions) |
nothing calls this directly
no test coverage detected