diff --git a/lib/step.js b/lib/step.js index b524a6a..f8a7127 100755 --- a/lib/step.js +++ b/lib/step.js @@ -86,7 +86,7 @@ function Step() { }; // Generates a callback generator for grouped results - next.group = function () { + next.group = function (resFirst) { var localCallback = next.parallel(); var counter = 0; var pending = 0; @@ -107,12 +107,14 @@ function Step() { pending++; return function () { pending--; - // Compress the error from any result to the first argument - if (arguments[0]) { + if (resFirst) { + result[index] = arguments[0]; + } else if (arguments[0]) { + // Compress the error from any result to the first argument error = arguments[0]; + // Send the other results as arguments + result[index] = arguments[1]; } - // Send the other results as arguments - result[index] = arguments[1]; if (!lock) { check(); } }; };