diff options
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 87d49f4..f058568 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -103,9 +103,7 @@ export default function queue(worker, concurrency, payload) { _insert(data, true, callback); }, remove: function (testFn) { - q._tasks = q._tasks.filter(function (node) { - return !testFn(node); - }) + q._tasks.remove(testFn); }, process: function () { // Avoid trying to start too many processing operations. This can occur |