(event: Event)
| 118 | } |
| 119 | |
| 120 | public onSendEvent(event: Event): void { |
| 121 | this.subscriptions.forEach((filters, subscriptionId) => { |
| 122 | if (filters.map(isEventMatchingFilter).some((isMatch) => isMatch(event))) { |
| 123 | logger('sending event to client %s: %o', this.clientId, event) |
| 124 | this.sendMessage(createOutgoingEventMessage(subscriptionId, event)) |
| 125 | } |
| 126 | }) |
| 127 | } |
| 128 | |
| 129 | private sendMessage(message: OutgoingMessage): void { |
| 130 | if (this.client.readyState !== WebSocket.OPEN) { |
nothing calls this directly
no test coverage detected