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

change node vless bunled

Browse Source
This commit is contained in:
zizifn
2023-04-23 01:31:58 +08:00
committed by zizifn
parent 16ac187f3a
commit 09a7fb6225
4 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apps/node-vless/src/main.ts
View File

@@ -281,9 +281,9 @@ async function socketAsyncWrite(ws: Duplex, chunk: Buffer) {
} }
async function wsAsyncWrite(ws: WebSocket, chunk: Uint8Array) { async function wsAsyncWrite(ws: WebSocket, chunk: Uint8Array) {
// 20m not transmitted to the network // 1m not transmitted to the network
while (ws.bufferedAmount > 1024 * 1024 * 20) { while (ws.bufferedAmount > 1024 * 1024 * 10) {
await delay(10); await delay(1);
} }
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
ws.send(chunk, (error) => { ws.send(chunk, (error) => {

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

@@ -5562,12 +5562,13 @@ exports.serverIndexPage = serverIndexPage;
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", ({ value: true })); Object.defineProperty(exports, "__esModule", ({ value: true }));
exports.processVlessHeader = exports.closeWebSocket = exports.makeReadableWebSocketStream = exports.delay = void 0; exports.vlessJs = exports.processVlessHeader = exports.closeWebSocket = exports.makeReadableWebSocketStream = exports.delay = void 0;
var vless_js_1 = __webpack_require__("../../libs/vless-js/src/lib/vless-js.ts"); var vless_js_1 = __webpack_require__("../../libs/vless-js/src/lib/vless-js.ts");
Object.defineProperty(exports, "delay", ({ enumerable: true, get: function () { return vless_js_1.delay; } })); Object.defineProperty(exports, "delay", ({ enumerable: true, get: function () { return vless_js_1.delay; } }));
Object.defineProperty(exports, "makeReadableWebSocketStream", ({ enumerable: true, get: function () { return vless_js_1.makeReadableWebSocketStream; } })); Object.defineProperty(exports, "makeReadableWebSocketStream", ({ enumerable: true, get: function () { return vless_js_1.makeReadableWebSocketStream; } }));
Object.defineProperty(exports, "closeWebSocket", ({ enumerable: true, get: function () { return vless_js_1.closeWebSocket; } })); Object.defineProperty(exports, "closeWebSocket", ({ enumerable: true, get: function () { return vless_js_1.closeWebSocket; } }));
Object.defineProperty(exports, "processVlessHeader", ({ enumerable: true, get: function () { return vless_js_1.processVlessHeader; } })); Object.defineProperty(exports, "processVlessHeader", ({ enumerable: true, get: function () { return vless_js_1.processVlessHeader; } }));
Object.defineProperty(exports, "vlessJs", ({ enumerable: true, get: function () { return vless_js_1.vlessJs; } }));
/***/ }), /***/ }),
@@ -6267,9 +6268,9 @@ function socketAsyncWrite(ws, chunk) {
} }
function wsAsyncWrite(ws, chunk) { function wsAsyncWrite(ws, chunk) {
return tslib_1.__awaiter(this, void 0, void 0, function* () { return tslib_1.__awaiter(this, void 0, void 0, function* () {
// 20m not transmitted to the network // 1m not transmitted to the network
while (ws.bufferedAmount > 1024 * 1024 * 20) { while (ws.bufferedAmount > 1024 * 1024 * 10) {
yield (0, vless_js_1.delay)(10); yield (0, vless_js_1.delay)(1);
} }
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
ws.send(chunk, (error) => { ws.send(chunk, (error) => {

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

File diff suppressed because one or more lines are too long

1
libs/vless-js/src/index.ts
View File

@@ -3,4 +3,5 @@ export {
makeReadableWebSocketStream, makeReadableWebSocketStream,
closeWebSocket, closeWebSocket,
processVlessHeader, processVlessHeader,
vlessJs,
} from './lib/vless-js'; } from './lib/vless-js';