diff options
| author | Hubert Argasinski <argasinski.hubert@gmail.com> | 2022-04-15 00:06:27 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-04-15 00:06:27 -0400 |
| commit | 6927a814ad505920179e5dd50e3ccb085f591273 (patch) | |
| tree | 88c9612da98d4ef764a9f8fc27188d3683332a50 /lib/internal/queue.js | |
| parent | 576ba747a2aca0e5392f2aad75f4a9912603b2d5 (diff) | |
| download | async-6927a814ad505920179e5dd50e3ccb085f591273.tar.gz | |
fix: update priorityQueue functionality to match queue (#1790)
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 886fe7a..75712c2 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -60,12 +60,11 @@ export default function queue(worker, concurrency, payload) { res(args) } - var item = { + var item = q._createTaskItem( data, - callback: rejectOnError ? - promiseCallback : + rejectOnError ? promiseCallback : (callback || promiseCallback) - }; + ); if (insertAtFront) { q._tasks.unshift(item); @@ -147,6 +146,12 @@ export default function queue(worker, concurrency, payload) { var isProcessing = false; var q = { _tasks: new DLL(), + _createTaskItem (data, callback) { + return { + data, + callback + }; + }, *[Symbol.iterator] () { yield* q._tasks[Symbol.iterator]() }, |