Add queue.error handler.

With the signature `function(error, task){}`

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) {