Fish Wang says to OwOQueue.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) } } } }at Mon, Jan 2, 2017 10:05 PM