fix: pending id error

koishijs · Aug 15, 2024 · a6bd059 · a6bd059
1 parent 572a2fa
commit a6bd059
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -306,10 +306,11 @@ export function apply(ctx: Context, config: Config) {
         : session.text('.waiting'))
 
       if (config.globalConcurrency) {
-        while (globalTasks.size >= config.globalConcurrency) {
-          globalPending.add(container.pop())
+        if (globalTasks.size >= config.globalConcurrency) {
+          const pendingId = container.pop()
+          globalPending.add(pendingId)
           await new Promise<void>((resolve) => ctx.once('novelai/finish', (id) => {
-            if (id === id) {
+            if (id === pendingId) {
               resolve()
             }
           }))