| 653 | } |
| 654 | } |
| 655 | function onError(cause: Event) { |
| 656 | ws.removeEventListener("message", onMessage) |
| 657 | ws.removeEventListener("close", onClose) |
| 658 | Deferred.doneUnsafe( |
| 659 | fiberSet.deferred, |
| 660 | Effect.fail( |
| 661 | new SocketError({ |
| 662 | reason: open ? |
| 663 | new SocketReadError({ |
| 664 | cause |
| 665 | }) : |
| 666 | new SocketOpenError({ |
| 667 | kind: "Unknown", |
| 668 | cause |
| 669 | }) |
| 670 | }) |
| 671 | ) |
| 672 | ) |
| 673 | } |
| 674 | function onClose(event: globalThis.CloseEvent) { |
| 675 | const code = typeof event.code === "number" ? event.code : 1001 |
| 676 | ws.removeEventListener("message", onMessage) |