Мне нужно выполнить что-то подобное:
async.waterfall([
function(callback){
writeStream = fs.createWriteStream(somePath);
writeStream.on('error', function (error) {
myFuncToLogError(error);
});
writeStream.write("Some words to write");
callback(null);
}], function (error) { ... });
Проблема в том, что функция во втором параметре не выполняется, если произошла ошибка в writeStream.