|
|
@ -38,7 +38,7 @@ wss.addListener("connection", function(ws) {
|
|
|
|
const socket = {
|
|
|
|
const socket = {
|
|
|
|
onMessage: (cb) => { ws.on("message", cb) },
|
|
|
|
onMessage: (cb) => { ws.on("message", cb) },
|
|
|
|
onError: (cb) => { ws.on("error", cb) },
|
|
|
|
onError: (cb) => { ws.on("error", cb) },
|
|
|
|
onClose: (cb) => { ws.on("onclose", cb) },
|
|
|
|
onClose: (cb) => { ws.on("close", cb) },
|
|
|
|
send: (data, cb) => { ws.send(data,cb) }
|
|
|
|
send: (data, cb) => { ws.send(data,cb) }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
const reader = new rpc.WebSocketMessageReader(socket);
|
|
|
|
const reader = new rpc.WebSocketMessageReader(socket);
|
|
|
|