Compare commits

...

2 Commits

Author SHA1 Message Date
Derrick Hammer 35bf05c25e
*Update dist 2023-04-16 05:38:59 -04:00
Derrick Hammer f842cd84c4
**createSocket does not need to be async 2023-04-16 05:38:36 -04:00
3 changed files with 3 additions and 5 deletions

View File

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

View File

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

View File

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