Skip to content
This repository was archived by the owner on Dec 21, 2021. It is now read-only.

Commit 900c2cd

Browse files
committed
fix: Clean up cancel promise.
1 parent b2ed376 commit 900c2cd

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

src/utils/iterators.js

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -222,14 +222,12 @@ export function CancelableGenerator(iterable, onFinally = () => {}, { timeout =
222222
}
223223

224224
cancelSignal.once('cancel', onCancel)
225-
const nextTask = iterator.next(...args)
226-
nextTask.finally(() => {
227-
cancelPromise.resolve()
228-
}).catch(() => {})
229225
return Promise.race([
230-
nextTask,
226+
iterator.next(...args),
231227
cancelPromise,
232-
])
228+
]).finally(() => {
229+
cancelPromise.resolve({ value: undefined, done: true })
230+
})
233231
},
234232
async throw(err) {
235233
cancelSignal.removeAllListeners()

0 commit comments

Comments
 (0)