(event: Event)
| 108 | } |
| 109 | |
| 110 | public onBroadcast(event: Event): void { |
| 111 | this.webSocketServer.emit(WebSocketServerAdapterEvent.Broadcast, event) |
| 112 | if (cluster.isWorker && typeof process.send === 'function') { |
| 113 | process.send({ |
| 114 | eventName: WebSocketServerAdapterEvent.Broadcast, |
| 115 | event, |
| 116 | }) |
| 117 | } |
| 118 | } |
| 119 | |
| 120 | public onSendEvent(event: Event): void { |
| 121 | this.subscriptions.forEach((filters, subscriptionId) => { |
no outgoing calls
no test coverage detected