将 Promise 与下载模块结合使用

我用蓝鸟来承诺。

我试图承诺下载模块.

这是我的实现：

Promise  = require('bluebird'),
download = require('download');

var methodNameToPromisify = ["download"];

function EventEmitterPromisifier(originalMethod) {
    // return a function
    return function promisified() {
        var args = [].slice.call(arguments);
        // Needed so that the original method can be called with the correct receiver
        var self = this;
        // which returns a promise
        return new Promise(function(resolve, reject) {
            // We call the originalMethod here because if it throws,
            // it will reject the returned promise with the thrown error
            var emitter = originalMethod.apply(self, args);

            emitter
                .on("response", function(data) {
                    resolve(data);
                })
                .on("data ", function(data) {
                    resolve(data);
                })
                .on("error", function(err) {
                    reject(err);
                })
                .on("close", function() {
                    resolve();
                });
        });
    };
};
download = { download: download };
Promise.promisifyAll(download, {
    filter: function(name) {
        return methodNameToPromisify.indexOf(name) > -1;
    },
    promisifier: EventEmitterPromisifier
});

然后使用它：

return download.downloadAsync(fileURL, copyTo, {});

我的问题是它没有下载所有文件（我有一个发送到此功能的列表），我做错了什么？

发射器确实发射multiple数据事件，每个接收到的数据块都有一个。然而，a仅代表one未来值，在您的情况下，您希望这是完整的响应。

resolve应该只被调用一次，以用传递的值履行承诺，然后解决。进一步的调用将不会产生任何效果 - 这就是为什么您只获得列表的第一部分。

相反，您需要积累所有数据，当流结束时，您可以用所有数据履行承诺。

var Promise  = require('bluebird'),
    download = require('download'),
    Buffer   = require('buffer'); // should be global anyway

exports = {
    downloadAsync: function promisifiedDownload() {
        var args = arguments, self = this;

        return new Promise(function(resolve, reject) {
            // We call the originalMethod here because if it throws,
            // it will reject the returned promise with the thrown error
            var emitter = download.apply(self, args);
            var buffers = [];

            emitter.on("data", function(data) {
                buffers.push(data);
            }).on("error", function(err) {
                reject(err);
            }).on("close", function() {
                resolve(Buffer.concat(buffers));
            });
        });
    };
};

_{Notice it's quite nonsensical to use promisifyAll when you only want to promisify a single method. I've omitted it for simplicity}

您还可以监听传入的response对象，并附加data直接监听它。然后您可以使用end event代替close.