summaryrefslogtreecommitdiff
path: root/lib/internal/queue.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/queue.js')
-rw-r--r--lib/internal/queue.js3
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js
index 2eb523a..e357447 100644
--- a/lib/internal/queue.js
+++ b/lib/internal/queue.js
@@ -101,6 +101,9 @@ export default function queue(worker, concurrency, payload) {
unshift: function (data, callback) {
_insert(data, true, callback);
},
+ remove: function (testFn) {
+ q._tasks.remove(testFn);
+ },
process: function () {
// Avoid trying to start too many processing operations. This can occur
// when callbacks resolve synchronously (#1267).