Skip to content

Commit 9929619

Browse files
committed
Provide error if available when works have done.
Signed-off-by: Toha <[email protected]>
1 parent 3e7566a commit 9929619

File tree

3 files changed

+7
-22
lines changed

3 files changed

+7
-22
lines changed

package-lock.json

+3-18
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@ntlab/work",
3-
"version": "1.1.2",
3+
"version": "1.1.3",
44
"description": "Nodejs queue and promise based work queue",
55
"main": "index.js",
66
"scripts": {

work.js

+3-3
Original file line numberDiff line numberDiff line change
@@ -92,9 +92,9 @@ class Work extends EventEmitter {
9292
return new Promise((resolve, reject) => {
9393
let id = ++seq;
9494
// always handler, called both on resolve and on reject
95-
const always = () => new Promise((resolve, reject) => {
95+
const always = err => new Promise((resolve, reject) => {
9696
if (typeof options.done == 'function') {
97-
options.done(w)
97+
options.done(w, err)
9898
.then(() => resolve())
9999
.catch(err => reject(err))
100100
;
@@ -127,7 +127,7 @@ class Work extends EventEmitter {
127127
// on error handler
128128
const stop = (idx, err) => {
129129
w.err = err;
130-
always()
130+
always(err)
131131
.then(() => {
132132
if (options.alwaysResolved) {
133133
debug('%d> [%d] rejected but return as resolved', id, idx);

0 commit comments

Comments
 (0)