fix(useAsyncQueue): trigger onFinished when the last task is rejected (#5144)

keeplearning66 · 9romise · web-flow · commit c4a460250262 · 2025-11-26T01:38:32.000Z
Co-authored-by: Vida Xie &lt;vida_2020@163.com&gt;
diff --git a/packages/core/useAsyncQueue/index.test.ts b/packages/core/useAsyncQueue/index.test.ts
@@ -135,4 +135,21 @@ describe('useAsyncQueue', () => {
       expect(finalTaskSpy).not.toHaveBeenCalled()
     })
   })
+
+  it('should trigger onFinished when the last task is rejected', async () => {
+    const p3 = () => {
+      return new Promise((resolve, reject) => {
+        setTimeout(() => {
+          reject(new Error('reject'))
+        }, 30)
+      })
+    }
+    const onFinishedSpy = vi.fn()
+    useAsyncQueue([p1, p2, p3], {
+      onFinished: onFinishedSpy,
+    })
+    await vi.waitFor(() => {
+      expect(onFinishedSpy).toHaveBeenCalledOnce()
+    })
+  })
 })
diff --git a/packages/core/useAsyncQueue/index.ts b/packages/core/useAsyncQueue/index.ts
@@ -127,6 +127,8 @@ export function useAsyncQueue<T extends any[], S = MapQueueTask<T>>(
 
         updateResult(promiseState.rejected, e)
         onError()
+        if (activeIndex.value === tasks.length - 1)
+          onFinished()
         return e
       })
   }, Promise.resolve())
