承诺在解决时抛出未处理的错误答案

【问题标题】：Promise throwing unhandled error on resolve承诺在解决时抛出未处理的错误
【发布时间】：2014-03-23 06:20:47
【问题描述】：

我有以下代码，但是当调用 resolve 时它会抛出：

Possibly unhandled Error: undefined
    at Promise$_rejecter (c:\projects\Test\promiseftp\node_modules\bluebird\js\main\promise.js:602:58)
    at WriteStream.<anonymous> (c:\projects\Test\promiseftp\index.js:45:33)
    at WriteStream.EventEmitter.emit (events.js:117:20)
    at fs.js:1598:14
    at Object.oncomplete (fs.js:107:15)

代码如下：

var Client = require('ftp');
var path = require('path');
var fs = require('fs');
var Promise = require('bluebird');


var c = new Client();

var connectionProperties = {
    host: "myhost",
    user: "myuser",
    password: "mypwd"
};

c.connect(connectionProperties);

var downloadFiles = new Promise.method(function () {
    return new Promise(function (reject, resolve) {
        c.on('ready', function () {
            c.list(function (err, list) {
                if (err) reject(err);
                list.forEach(function (element, index, array) {
                    //Ignore directories
                    if (element.type === 'd') {
                        console.log('ignoring directory ' + element.name);
                        return;
                    }
                    //Ignore non zips
                    if (path.extname(element.name) !== '.zip') {
                        console.log('ignoring file ' + element.name);
                        return;
                    }

                    c.get(element.name, function (err, stream) {
                        if (err) reject(err);
                        console.log(element.name);
                        stream.once('close', function () {
                            //c.end();
                            //resolve();
                        });

                        var pipeaction = stream.pipe(fs.createWriteStream(element.name));
                        pipeaction.on('close', function () {
                            console.log('close');
                            //THROWS HERE!
                            resolve();
                        });

                    });
                });
            });
        });
    });

});


downloadFiles().then(function () {
    console.log('woot');
});

有什么想法吗？

【问题讨论】：

附带说明 - 当您使用 Promise.method 时，您可以跳过整个 'return new Promise' 位，您可以改为 - 就像在 .then 调用中一样 - 返回解决并抛出拒绝。另外，如果我是你，我也会承诺 ftp 客户端。另外，close 是否被记录？它是否到达close 事件？
Close 被记录两次。即使在做出 ftp 承诺后，我也会遇到同样的错误
你不能两次解决一个promise，看起来这是forEach的问题。但是，您确定它会引发resolve() 吗？该错误看起来更像是调用了reject()。
@Bergi 他已经定义了new Promise(function(reject, resolve){}) - 参数应该是resolve, reject。参数顺序错误时，调用resolve()相当于调用真实的reject(undefined)

标签： javascript node.js promise bluebird

【解决方案1】：

请不要将回调和承诺混为一谈，看看它有多简单：

when(c, "ready").then(function(){
    return c.listAsync();
}).filter(function(element) {
    return element.type !== "d" && path.extname(element.name) === ".zip";
}).map(function(element) {
    return c.getAsync(element.name).then(function(stream) {
        return when(stream.pipe(fs.createWriteStream(element.name)), "close");
    })
}).then(function(){
    console.log("all files copied");
});

样板：

var path = require('path');
var fs = require('fs');
var Promise = require('bluebird');
var Client = require('ftp');
Promise.promisifyAll(Client.prototype);

var c = new Client();

var connectionProperties = {
    host: "myhost",
    user: "myuser",
    password: "mypwd"
};

c.connect(connectionProperties);

function when(obj, event) {
    return new Promise(function(resolve) {
        obj.on(event, resolve);
    });
}

【讨论】：

【解决方案2】：

我终于让它工作并在博客上发布了结果 - http://blog.jonathanchannon.com/2014/03/22/using-node-and-ftp-with-promises/

【讨论】：