|
|
@ -49,7 +49,7 @@ var caching = function (args) { |
|
|
|
var work_args = Array.prototype.slice.call(arguments, 0); |
|
|
|
if (work_args[0]) { // assume first arg is an error
|
|
|
|
self.queues[key].forEach(function (done) { |
|
|
|
done.apply(null, work_args); |
|
|
|
done.call(null, work_args[0]); |
|
|
|
}); |
|
|
|
delete self.queues[key]; |
|
|
|
return; |
|
|
@ -61,14 +61,11 @@ var caching = function (args) { |
|
|
|
done.call(null, err); |
|
|
|
}); |
|
|
|
} |
|
|
|
else if (!err) { |
|
|
|
else { |
|
|
|
self.queues[key].forEach(function (done) { |
|
|
|
done.apply(null, work_args); |
|
|
|
}); |
|
|
|
} |
|
|
|
else { |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
delete self.queues[key]; |
|
|
|
}); |
|
|
|