fix(core): update
This commit is contained in:
@@ -268,10 +268,19 @@ JNj2Dr5H0XoLFFnvuvzcRbhlJ9J67JzR+7g=
|
||||
// console.log("upstream to client", message);
|
||||
wsIncoming.send(message, { binary: isBinary });
|
||||
});
|
||||
wsIncoming.on("error", () => wsOutgoing.terminate());
|
||||
wsOutgoing.on("error", () => wsIncoming.terminate());
|
||||
wsIncoming.on("close", () => wsOutgoing.terminate());
|
||||
wsOutgoing.on("close", () => wsIncoming.terminate());
|
||||
const terminateWsOutgoing = () => {
|
||||
wsOutgoing.terminate();
|
||||
console.log('terminated outgoing ws.');
|
||||
}
|
||||
wsIncoming.on("error", () => terminateWsOutgoing());
|
||||
wsIncoming.on("close", () => terminateWsOutgoing());
|
||||
|
||||
const terminateWsIncoming = () => {
|
||||
wsIncoming.terminate();
|
||||
console.log('terminated incoming ws.');
|
||||
}
|
||||
wsOutgoing.on("error", () => terminateWsIncoming());
|
||||
wsOutgoing.on("close", () => terminateWsIncoming());
|
||||
|
||||
});
|
||||
this.httpsServer.keepAliveTimeout = 600 * 1000;
|
||||
|
Reference in New Issue
Block a user