diff --git a/src/index.ts b/src/index.ts index 0b4d3e3..7c0ea18 100644 --- a/src/index.ts +++ b/src/index.ts @@ -150,7 +150,11 @@ export class Socket extends EventEmitter { } end(): void { - callModule(DHT_MODULE, "close", { id: this.id }); + callModule(DHT_MODULE, "socketExists", { id: this.id }).then(([exists]: ErrTuple) => { + if (exists) { + callModule(DHT_MODULE, "close", { id: this.id }); + } + }); } private ensureEvent(event: string): void {