summaryrefslogtreecommitdiff
path: root/node_modules/fastq/queue.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/fastq/queue.js')
-rw-r--r--node_modules/fastq/queue.js1
1 files changed, 1 insertions, 0 deletions
diff --git a/node_modules/fastq/queue.js b/node_modules/fastq/queue.js
index 03fe1127..d5a8406d 100644
--- a/node_modules/fastq/queue.js
+++ b/node_modules/fastq/queue.js
@@ -118,6 +118,7 @@ function fastqueue (context, worker, concurrency) {
current.release = release
current.value = value
current.callback = done || noop
+ current.errorHandler = errorHandler
if (_running === self.concurrency || self.paused) {
if (queueHead) {