使用Meteor.setTimeout
:
start: function() {
Meteor.setTimeout(function() {
let data = Strategy.find({}, {limit: 5}).fetch();
for (let i = 0; i < data.length; ++i) {
mqttClient.publish("test", data[i].charge);
}
}, 1000);
}
并了解为什么要使用它与香草 setTimeout()。
编辑对于变量:
start: function() {
let data = Strategy.find({}, {limit: 5}).fetch();
for (let i = 0; i < data.length; ++i) {
Meteor.setTimeout(function() {
mqttClient.publish("test", data[i].charge);
}, data[i].duration);
}
}
编辑你可以用 RawCollection 对象做你想做的事,将它的 maxTimeMS 设置为
var rawCollection = Strategy.rawCollection();
// Number.MAX_SAFE_INTEGER should be sufficient time
var cursor = rawCollection.find({}).maxTimeMS(Number.MAX_SAFE_INTEGER );
var myData = fetchCursor(cursor);
var fetchCursor = Meteor.wrapAsync(function
fetchCursor (cursor, cb) {
cursor.each(function (err, doc) {
if (err) return cb(err);
if (!doc) return cb(null, { done: true }); // no more documents
// use doc here.
});
});