dist/proxies/multiSocket.d.ts

@@ -25,7 +25,7 @@ export default class MultiSocketProxy extends Proxy {
     handleClosePeer(peer: Peer): Promise<void>;
     get(pubkey: Uint8Array): PeerEntity | undefined;
     update(pubkey: Uint8Array, data: Partial<PeerEntity>): void;
-    createSocket(options: TcpSocketConnectOpts): typeof this.socketClass;
+    createSocket(options: TcpSocketConnectOpts): Promise<typeof this.socketClass>;
     private _registerOpenSocketMessage;
     private _registerWriteSocketMessage;
     private _registerCloseSocketMessage;

dist/proxies/multiSocket.js

@@ -136,7 +136,7 @@ class MultiSocketProxy extends proxy_js_1.default {
             },
         });
     }
-    createSocket(options) {
+    async createSocket(options) {
         if (!this._peers.size) {
             throw new Error("no peers found");
         }

src/proxies/multiSocket.ts

@@ -172,7 +172,9 @@ export default class MultiSocketProxy extends Proxy {
     } as PeerEntity);
   }
 
-  public createSocket(options: TcpSocketConnectOpts): typeof this.socketClass {
+  public async createSocket(
+    options: TcpSocketConnectOpts
+  ): Promise<typeof this.socketClass> {
     if (!this._peers.size) {
       throw new Error("no peers found");
     }