diff options
-rw-r--r-- | lib/internal/queue.js | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index 9a1f77f..544fae5 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -61,6 +61,10 @@ export default function queue(worker, concurrency, payload) { }); task.callback.apply(task, args); + + if (args[0] != null) { + q.error(args[0], task.data); + } }); if (workers <= (q.concurrency - q.buffer) ) { @@ -85,6 +89,7 @@ export default function queue(worker, concurrency, payload) { buffer: concurrency / 4, empty: noop, drain: noop, + error: noop, started: false, paused: false, push: function (data, callback) { |