https://www.npmjs.com/package/tress - Вот сам пакет, хочу использовать как очередь.
Объявляю, в примере concurrency 2
var myTressJob = tress(function(item, done) {
console.log(item.id)
}, 2)
Под очередью я понимаю так, есть крон который исполняется каждые десять минут и вытаскивает из БД записи, скажем 400 штук, прохожусь по массиву и делаю myTressJob.push(item), и все крон заканчивает работу, и начинает работу очередь.
Ожидаю в консоли увидеть все id элементов, а в реальности получаю столько сколько concurrency
Я что то не понял? Как правильно с ним отработать?