Dispark/edgetunnel
1
0
Fork 0
mirror of https://github.com/lush2020/edgetunnel.git synced 2026-03-24 09:08:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix nodejs exit issue

Browse Source
This commit is contained in:
zizifn
2023-03-11 20:19:57 +08:00
committed by zizifn
parent 403f4abf24
commit 981bdf880f
3 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
dist/apps/node-vless/main.js vendored
View File

@@ -5596,6 +5596,10 @@ function makeReadableWebSocketStream(ws, earlyDataHeader, log) {
return new ReadableStream({ return new ReadableStream({
start(controller) { start(controller) {
ws.addEventListener('message', (e) => tslib_1.__awaiter(this, void 0, void 0, function* () { ws.addEventListener('message', (e) => tslib_1.__awaiter(this, void 0, void 0, function* () {
// is stream is cancel, skip controller.enqueue
if (readableStreamCancel) {
return;
}
const vlessBuffer = e.data; const vlessBuffer = e.data;
// console.log('MESSAGE', vlessBuffer); // console.log('MESSAGE', vlessBuffer);
// console.log(`message is ${vlessBuffer.byteLength}`); // console.log(`message is ${vlessBuffer.byteLength}`);
@@ -6235,6 +6239,7 @@ function connect2Remote(port, host, log) {
const remoteSocket = (0, node_net_1.connect)({ const remoteSocket = (0, node_net_1.connect)({
port: port, port: port,
host: host, host: host,
// https://github.com/nodejs/node/pull/46587
// autoSelectFamily: true, // autoSelectFamily: true,
}, () => { }, () => {
log(`connected`); log(`connected`);

2
dist/apps/node-vless/main.js.map vendored
View File

File diff suppressed because one or more lines are too long

4
libs/vless-js/src/lib/vless-js.ts
View File

@@ -18,6 +18,10 @@ export function makeReadableWebSocketStream(
return new ReadableStream<ArrayBuffer>({ return new ReadableStream<ArrayBuffer>({
start(controller) { start(controller) {
ws.addEventListener('message', async (e: { data: ArrayBuffer }) => { ws.addEventListener('message', async (e: { data: ArrayBuffer }) => {
// is stream is cancel, skip controller.enqueue
if (readableStreamCancel) {
return;
}
const vlessBuffer: ArrayBuffer = e.data; const vlessBuffer: ArrayBuffer = e.data;
// console.log('MESSAGE', vlessBuffer); // console.log('MESSAGE', vlessBuffer);
// console.log(`message is ${vlessBuffer.byteLength}`); // console.log(`message is ${vlessBuffer.byteLength}`);