Метеорная задержка в итерации через коллекцию

Question

Здравствуйте, я хочу создать задержку в моем методе на стороне сервера Meteor, когда я выполняю итерацию по коллекции. Метод Meteor._sleepForMs вызывает исключения и перезапускает приложение каждый раз. Какие подходы существуют для задержки сбора-итерации?

Meteor.methods({ 
.... 
start: function() { 
let data = Strategy.find({}, {limit: 5}).fetch(); 
     for (let i = 0; i < data.length; ++i) { 
      mqttClient.publish("test", data[i].charge); 
      Meteor._sleepForMs(data[i].duration*1000); 
     } 
    } 

Answer 1

Использование 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); 
} 

, а также увидеть why to use that vs vanilla setTimeout().

EDIT Для переменной:

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); 
    } 
} 

EDIT Вы можете делать то, что вы хотите с объектом 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. 
    }); 
}); 

Answer 2

Другой подход заключается в следующем, но после 30 итераций это не задерживает время продолжительности поля и повторяет случайное значение между 1-10 секундами. Кстати, у меня есть тысячи документов в моем db.

var Future = Npm.require('fibers/future'); 
       var future = new Future(); 
       Meteor.setTimeout(function() { 
        future.return(); 
        let d = `${moment(data[i].t).format("YYYY-MM-DD HH:mm:ss")} ${data[i].field}`; 
        mqttClient.publish("test", d); 
       }, data[i].duration*1000); 
       future.wait();