Fish Wang says to OwO
Queue.helpers = { mergeTask: function(a, b) { return function merged(cb) { var handle, stopped = false; handle = a(function (err, data) { if (err) { return cb(err); } if (stopped) { cb(data); } handle = b(function (err, data2) { if (err) { return cb(err); } cb(null, [data, data2]) }) }) return function wrapHandle(data) { if (data === 'stop') { stopped = true; } handle(data) } } } }