From c845a4fc4f3c71f6a08bbde4fa0381f4b87b1253 Mon Sep 17 00:00:00 2001
From: codytseng <codytseng@outlook.com>
Date: Wed, 19 Nov 2025 09:57:57 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=F0=9F=90=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/services/client.service.ts | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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<string>()
-    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)
         }
       })