From ebc56a18992b9b4253c955efb7535ef372a95879 Mon Sep 17 00:00:00 2001
From: Charles Francoise <charles.francoise@gmail.com>
Date: Sat, 23 Nov 2019 16:19:14 +0100
Subject: [PATCH] add errorHandler

---
 src/createWorker.js | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/createWorker.js b/src/createWorker.js
index 93ca580..0f42c1e 100644
--- a/src/createWorker.js
+++ b/src/createWorker.js
@@ -19,6 +19,7 @@ module.exports = (_options = {}) => {
   const id = getId('Worker', workerCounter);
   const {
     logger,
+    errorHandler,
     ...options
   } = resolvePaths({
     ...defaultOptions,
@@ -132,6 +133,11 @@ module.exports = (_options = {}) => {
       resolves[action]({ jobId, data: d });
     } else if (status === 'reject') {
       rejects[action](data);
+      if (errorHandler) {
+        errorHandler(data);
+      } else {
+        throw Error(data);
+      }
     } else if (status === 'progress') {
       logger(data);
     }