node.js - Nodejs Async Waterfall，另一个流控制？

Question

我正在使用 async.waterfall，我想做一些这样的事情：

通过返回诸如 Promise 之类的东西来保持 async.waterfall 的结果。所以，我可以把这两部分分开。

function Action1(){

    return async.waterfall([
        function step1(callback){
            ...
            callback(null, data);
        },
        function step2(data, callback){
            ...
            callback(null, data);
        },
        function step3(data, callback){
            ...
            callback(null, data);
        }
    ]);
}


Action1().then(function(result){
    // obtain the final result here
});

但是，我能找到的是：最终的回调只能作为参数注入到瀑布函数中。

async.waterfall([
    function(callback) {
        ...
        callback(null, data);
    },
    function(data, callback) {
        ...
        callback(null, data);
    },
    function(data, callback) {
        ...
        callback(null, data);
    }
], function (err, result) {

    // final callback
    ...
});

对我有什么建议，以实现预期的编程结构？或者除了异步之外的任何选择都允许这种模式？

Answer 1

你可能应该去蓝鸟。

像这样的async代码：

async.waterfall([
    function(callback) {
        callback(null, 'one', 'two');
    },
    function(arg1, arg2, callback) {
      // arg1 now equals 'one' and arg2 now equals 'two'
        callback(null, 'three');
    },
    function(arg1, callback) {
        // arg1 now equals 'three'
        callback(null, 'done');
    }
], function (err, result) {
    // result now equals 'done'
});

可以这样写（使用 Blubird）：

Promise.resolve(['one', 'two']).spread(function(arg1, arg2) {
    // arg1 now equals 'one' and arg2 now equals 'two'
    return 'three';
}).then(function(arg1) {
    // arg1 now equals 'three'
    return 'done';
}).then(function(result) {
    // result now equals 'done'
});

您可以参考http://bluebirdjs.com/docs/coming-from-other-libraries.html#coming-from-async-module了解更多信息。