(
event: T,
data: InferCustomEventPayload<T>,
socket: WebSocketRaw,
)
| 285 | } |
| 286 | |
| 287 | const emitCustomEvent = <T extends string>( |
| 288 | event: T, |
| 289 | data: InferCustomEventPayload<T>, |
| 290 | socket: WebSocketRaw, |
| 291 | ) => { |
| 292 | const listeners = customListeners.get(event) |
| 293 | if (!listeners?.size) return |
| 294 | |
| 295 | const client = getSocketClient(socket) |
| 296 | for (const listener of listeners) { |
| 297 | listener(data, client) |
| 298 | } |
| 299 | } |
| 300 | |
| 301 | wss.on('connection', (socket) => { |
| 302 | socket.on('message', (raw) => { |
no test coverage detected