包装在 promise JavaScript 通用函数中[重复]

Question

如何用 promise 包装一个可以在内部具有同步/异步功能的函数？

我已经调用了如下函数

action[fn](req, res);

在函数 fn（在下面的例子中）运行可以有内部（我对每个函数都使用动态调用）同步 或 a-sync，如下例所示，

1. 建议如何将其包装在 promise 中。
2. 如果有错误如何处理...

我使用 nodeJS 应用程序

 run: function (req, res, filePath) {
        var writeStream = fs.createWriteStream(fileRelPath, {flags: 'w'});
        req.pipe(writeStream);
        req.on("end", function () {
            console.log("Finish to update data file")
        });
        res.end("File " + filePath + " saved successfully");
    }

Answer 1

例如，我们可以使用 Q libary 和 defer，如下所示：

run: function (req, res, filePath) {
        var d = Q.defer();

        var writeStream = fs.createWriteStream(fileRelPath, {flags: 'w'});
        req.pipe(writeStream);
        req.on("end", function () {
            console.log("Finish to update data file");
            d.resolve();
        });

        req.on("error", function (err) {
            d.reject(err);
        });



        return d.promise.then(function(){
            res.end("File " + filePath + " saved successfully");
        }).catch(function(err){
            //handle error
        })
    }

在此代码中，promise 将在 req end 事件之后解析，然后 res.end，但我建议创建另一个方法来完成响应并使用方法 run 中的 promise。祝你好运！