fix(cli):fix the incorrect count

emqx · Jun 27, 2023 · 4894a40 · 4894a40
1 parent e163aa2
commit 4894a40
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cli/src/lib/conn.ts b/cli/src/lib/conn.ts
@@ -86,7 +86,7 @@ const benchConn = async (options: BenchConnectOptions) => {
         if (isNewConnArray[i - 1]) {
           interactive.success('[%d/%d] - Connected', connectedCount, count)
 
-          if (i === count) {
+          if (connectedCount === count) {
             const end = Date.now()
             signale.info(`Done, total time: ${(end - start) / 1000}s`)
           }

diff --git a/cli/src/lib/pub.ts b/cli/src/lib/pub.ts
@@ -231,7 +231,7 @@ const multiPub = async (commandType: CommandType, options: BenchPublishOptions |
             })
           }, messageInterval)
 
-          if (i === count) {
+          if (connectedCount === count) {
             const connEnd = Date.now()
 
             signale.info(`Created ${count} connections in ${(connEnd - connStart) / 1000}s`)

diff --git a/cli/src/lib/sub.ts b/cli/src/lib/sub.ts
@@ -186,7 +186,7 @@ const benchSub = async (options: BenchSubscribeOptions) => {
                 }
               })
 
-              if (i === count && topic[topic.length - 1] === t) {
+              if (connectedCount === count && topic[topic.length - 1] === t) {
                 const connEnd = Date.now()
 
                 signale.info(`Created ${count} connections in ${(connEnd - connStart) / 1000}s`)