(
customServer?: import('http').Server,
_req?: IncomingMessage
)
| 428 | } |
| 429 | |
| 430 | private setupWebSocketHandler( |
| 431 | customServer?: import('http').Server, |
| 432 | _req?: IncomingMessage |
| 433 | ) { |
| 434 | if (!this.didWebSocketSetup) { |
| 435 | this.didWebSocketSetup = true |
| 436 | customServer = customServer || (_req?.socket as any)?.server |
| 437 | |
| 438 | if (customServer) { |
| 439 | customServer.on('upgrade', async (req, socket, head) => { |
| 440 | this.upgradeHandler(req, socket, head) |
| 441 | }) |
| 442 | } |
| 443 | } |
| 444 | } |
| 445 | |
| 446 | getRequestHandler(): RequestHandler { |
| 447 | return async ( |
no test coverage detected