LumeWeb
/
libhyperproxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:b3d6fd46683b01c1a7f10b60e48079e475c4257d
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
..
compare: LumeWeb:35bf05c25ec48099017a35b9c7953a8e38f6c24a
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

No commits in common. "b3d6fd46683b01c1a7f10b60e48079e475c4257d" and "35bf05c25ec48099017a35b9c7953a8e38f6c24a" have entirely different histories.
b3d6fd4668 ... 35bf05c25e

2 changed files with 2 additions and 5 deletions
Show Stats Expand all files Collapse all files

3
dist/proxies/multiSocket.js vendored
View File

@ -68,7 +68,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
socketClass; socketClass;
_peers = new Map(); _peers = new Map();
_nextPeer; _nextPeer = (0, util_js_1.roundRobinFactory)(this._peers);
_server = false; _server = false;
_allowedPorts = []; _allowedPorts = [];
constructor(options) { constructor(options) {
@ -87,7 +87,6 @@ class MultiSocketProxy extends proxy_js_1.default {
if (options.server) { if (options.server) {
this._server = true; this._server = true;
} }
this._nextPeer = (0, util_js_1.roundRobinFactory)(this._peers);
} }
_socketMap = new Map(); _socketMap = new Map();
get socketMap() { get socketMap() {

4
src/proxies/multiSocket.ts
View File

@ -89,10 +89,9 @@ export default class MultiSocketProxy extends Proxy {
await conn.init(); await conn.init();
this.emit("peer", conn); this.emit("peer", conn);
} }
private socketClass: any; private socketClass: any;
private _peers: Map<string, PeerEntity> = new Map<string, PeerEntity>(); private _peers: Map<string, PeerEntity> = new Map<string, PeerEntity>();
private _nextPeer; private _nextPeer = roundRobinFactory(this._peers);
private _server = false; private _server = false;
private _allowedPorts = []; private _allowedPorts = [];
@ -110,7 +109,6 @@ export default class MultiSocketProxy extends Proxy {
if (options.server) { if (options.server) {
this._server = true; this._server = true;
} }
this._nextPeer = roundRobinFactory(this._peers);
} }
private _socketMap = new Map<number, number>(); private _socketMap = new Map<number, number>();