当我更新集合时，我的客户端订阅例程没有刷新:

server/publish.js

Meteor.publish('decisions', function (decisionCursor) {
    return Decisions.find({ active: true }, { limit: 20, skip: decisionCursor });
});

Meteor.publish('decisionsToModerate', function (decisionCursor) {
    return Decisions.find({ active: false }, { sort: { createdAt: -1 }, limit: 1, skip: decisionCursor });
});

我为我的客户订阅了这两个集合出版物，当它获取所有数据时，它会创建一个 session 对象，其中包含我需要的一些东西。

client/client.js

Meteor.startup(function () {
    SimpleSchema.debug = true;
    Deps.autorun(function () {
        Meteor.subscribe("decisions", Number(Session.get('decisionCursor')), function () {
            var decisionsVoted = {};
            Decisions.find({
                active: true
            }).forEach(function (decision) {
                var userVoted = Meteor.users.findOne({
                    "_id": Meteor.userId(),
                    "profile.votes.decision": decision._id
                }) != null ? Meteor.users.findOne({
                    "_id": Meteor.userId(),
                    "profile.votes.decision": decision._id
                }) : false;

                var ipVoted = Votes.findOne({
                    "ip": headers.get('x-forwarded-for'),
                    "votes.decision": decision._id
                }) != null ? true : false;
                if (ipVoted || userVoted)
                    decisionsVoted[decision._id] = {
                        voted: true,
                        blue: decision.blueTotal,
                        red: decision.redTotal,
                        bluePer: Math.round(decision.blueTotal * 100) / (decision.blueTotal + decision.redTotal),
                        redPer: Math.round(decision.redTotal * 100) / (decision.blueTotal + decision.redTotal)
                    };

            });
            Session.set('decisionsVoted', decisionsVoted);
        });
        Meteor.subscribe("decisionsToModerate", Number(Session.get('decisionCursor')));
    });
});

client/lib/environment.js

activeDecisions = function() {
    var decisions = Decisions.find({active: true});
    console.log(decisions.fetch().length);
    return decisions;
};
moderateDecisions = function() {
    return Decisions.find({active: false});
};

client/views/home/home.js

'click': function (event) {
    event.preventDefault();
    var decisionId = Session.get("selected_decision");
    var hasVoted = Session.get('decisionsVoted')[decisionId] ? Session.get('decisionsVoted')[decisionId].voted : false;

    Meteor.call("vote", decisionId, 'blue', hasVoted, function (error, result) {
        if (!error && result === true) {
            console.log(Session.get('decisionsVoted')[decisionId]); // UNDEFINED
        }
    });
},

当更新成功时，客户端订阅应该更新在我的 session 对象中创建一个新对象，对吗？因为集合已更改，所以在服务器中发布已刷新...但它不会刷新，我评论的 //UNDEFINED 而不是返回我的新对象正在返回 UNDEFINED

我不知道这是 Meteor 的行为还是我遗漏了什么...我尝试更新传递给发布方法 decisionCursor 的参数以强制更新但没有任何反应Session.set('decisionCursor', Session.get('decisionCursor'));

编辑: 似乎如果我使用 Session.set('decisionCursor', Session.get('decisionCursor') + 1);(注意 +1 ) 它被刷新但不在结果函数内部，如果我再次单击它会检测到添加了新对象...但我需要在结果函数内部刷新它(在我的 home.js 单击事件中)

最佳答案

This (excellent) article可能有帮助。换句话说:

...on the server, Meteor’s reactivity is limited to cursors returned by Meteor.publish() functions. The direct consequence of this is that unlike on the client, code will not magically re-run whenever data changes.

关于javascript - meteor 发布订阅不是被动的，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/23772693/