dist/proxies/multiSocket.js

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

src/proxies/multiSocket.ts

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