summaryrefslogtreecommitdiff
path: root/lib/internal/queue.js
diff options
context:
space:
mode:
authorAlex Early <alexander.early@gmail.com>2017-04-08 20:34:34 -0700
committerGitHub <noreply@github.com>2017-04-08 20:34:34 -0700
commit8f58dbd1da3da50ee820a80c1d5088ca37a1d53a (patch)
treed4b1ce37f30b6dab380928bc889720cd8882dbd4 /lib/internal/queue.js
parent7f913b6d6a951bef9b287c0e186664b655b90c73 (diff)
parent07402822c3125a019c3060104eb7da54e0ccc5b6 (diff)
downloadasync-8f58dbd1da3da50ee820a80c1d5088ca37a1d53a.tar.gz
Merge pull request #1397 from caolan/linked-list-methods
queue.remove()
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).