diff --git a/src/services/client.service.ts b/src/services/client.service.ts index 868da3f..745db5e 100644 --- a/src/services/client.service.ts +++ b/src/services/client.service.ts @@ -384,7 +384,7 @@ class ClientService extends EventTarget { // eslint-disable-next-line @typescript-eslint/no-this-alias const that = this const _knownIds = new Set() - let startedCount = 0 + let startedCount = relays.length let eosedCount = 0 let eosed = false let closedCount = 0 @@ -396,7 +396,6 @@ class ClientService extends EventTarget { subPromises.push(startSub()) async function startSub() { - startedCount++ const relay = await that.pool.ensureRelay(url, { connectionTimeout: 5000 }).catch(() => { return undefined }) @@ -451,6 +450,7 @@ class ClientService extends EventTarget { .then(() => { hasAuthed = true if (!eosed) { + startedCount++ subPromises.push(startSub()) } }) @@ -718,7 +718,7 @@ class ClientService extends EventTarget { resolve(events) } }, - onclose: () => { + onAllClose: () => { resolve(events) } })