失败：col.insert({}, cb) 与成功 col.insert({}, () => cb())

Question

正在寻找解释。尝试了没有粗箭头的变体，结果相同。使用

"mongodb": "^2.2.24",

以下代码不起作用（我稍后加载了值，但它们不存在）

addCollections(data, cb) {
    var names = Object.keys(data);
    async.each(names, (name, cb1) => {
        db.createCollection(name).then((collection) => {
            collection.insert(data[name], cb1);
        }).catch(cb1);
    }, cb)
},

但是这段代码确实有效：

addCollections(data, cb) {
    var names = Object.keys(data);
    async.each(names, (name, cb1) => {
        db.createCollection(name).then((collection) => {
            collection.insert(data[name], (a, b) => {
                // reverted this comment bc Im debugging this
                cb1();
            })
        }).catch(cb1);
    }, cb);
},

以下也适用：

addCollections(data, cb) {
    var names = Object.keys(data);
    async.each(names, (name, cb1) => {
        db.createCollection(name).then((collection) => {
            collection.insert(data[name], cb1);
        }).catch(cb1);
    }, () => {
        setTimeout(function() {
            cb()
        }, 10);
    })
},

按照@Adam 的要求调用堆栈（使用实验室作为测试库）：

execute(fixture, verify, cb) {
    db.connect(() => {
        db.drop(() => {
            db.addCollections(fixture, () => {
                this.executeNode(fixture, verify, cb);
            });
        });
    });
},

executeNode(fixture, verify, cb) {
    var injectOptions = {
        method: 'GET',
        url: 'myUrl
    };

    server.inject(injectOptions, function (response) {
        verify(response.result);
        db.close(cb);
    });
},

test('default', (done) => {
    fb.execute(fixture, verify, done);
});

Answer 1

我能想到的唯一解释是 collection.insert 使用真实参数调用其回调；也就是说，如果我们假设 nodeback 约定，它会导致错误。

因此，您的测试失败是预期。

那么为什么其他两个代码"work"？

在第二个代码段中，() => { cb1(); } 作为 insert 的回调（隐含地？）忽略错误，无论它是否被调用它都不会将任何东西传递给 cb1。
在第三个片段中，async.each 将失败（正确地）并调用其回调 () => { setTimeout(function(){cb()}, 10); } 并出现错误 - whcih 再次隐式忽略它并且永远不会将其传递给 cb。超时是不必要的，each(…, () => cb()) 会有相同的结果。

失败：col.insert({}, cb) 与成功 col.insert({}, () => cb())

FAIL: col.insert({}, cb) vs SUCCESS col.insert({}, () => cb())

javascript

mongodb

async.js