(cause: Event)
| 470 | upgrade.socket.removeEventListener("close", onFailure) |
| 471 | } |
| 472 | const onFailure = (cause: Event) => { |
| 473 | cleanup() |
| 474 | upgrade.socket.removeEventListener("message", buffer) |
| 475 | buffered.length = 0 |
| 476 | resume(Effect.fail( |
| 477 | new Error.HttpServerError({ |
| 478 | reason: new Error.RequestParseError({ |
| 479 | request: this, |
| 480 | cause, |
| 481 | description: "WebSocket upgrade failed before open" |
| 482 | }) |
| 483 | }) |
| 484 | )) |
| 485 | } |
| 486 | const onOpen = () => { |
| 487 | cleanup() |
| 488 | resume(Socket.fromWebSocket( |
nothing calls this directly
no test coverage detected