diff options
| -rw-r--r-- | lib/internal/queue.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index e3887cb..41d6c90 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -15,7 +15,7 @@ export default function queue(worker, concurrency, payload) { throw new Error('Concurrency must not be zero'); } - function _insert(data, pos, callback) { + function _insert(data, insertAtFront, callback) { if (callback != null && typeof callback !== 'function') { throw new Error('task callback must be a function'); } @@ -35,7 +35,7 @@ export default function queue(worker, concurrency, payload) { callback: callback || noop }; - if (pos) { + if (insertAtFront) { q._tasks.unshift(item); } else { q._tasks.push(item); |