(message)
| 80 | clientRequestPrincipal: clientRequestPrincipalFromRequest(request), |
| 81 | }, |
| 82 | send(message) { |
| 83 | if (socket.readyState !== WebSocket.OPEN) return |
| 84 | if (socket.bufferedAmount > maxBufferedBytes) { |
| 85 | socket.close(1013, "client is too far behind") |
| 86 | runtime.notify("connection/lagged", { connectionId, bufferedAmount: socket.bufferedAmount }) |
| 87 | return |
| 88 | } |
| 89 | socket.send(JSON.stringify(message)) |
| 90 | }, |
| 91 | close() { |
| 92 | socket.close() |
| 93 | }, |