diff options
| author | Hubert Argasinski <argasinski.hubert@gmail.com> | 2022-02-14 02:11:47 -0500 |
|---|---|---|
| committer | Hubert Argasinski <argasinski.hubert@gmail.com> | 2022-02-14 02:11:47 -0500 |
| commit | 05fd72164dfdc10703edb993839f41b10cbca516 (patch) | |
| tree | de7d5cf1bdc5d9b9279765c521aa19b836125571 /lib/internal/queue.js | |
| parent | b8d1115888c335bdf55d53fa0a943859420c259c (diff) | |
| download | async-05fd72164dfdc10703edb993839f41b10cbca516.tar.gz | |
add a guard to the task callback drainschedule-drain
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index fdbabbc..fffea99 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -115,8 +115,10 @@ export default function queue(worker, concurrency, payload) { trigger('unsaturated') } - if (q.idle()) { + if (q.idle() && !drainScheduled) { + drainScheduled = true trigger('drain') + drainScheduled = false } q.process(); }; |