🕵
Size: a a a
2020 January 15
🕵
Очередь же разная
KG
если исполнение функции будет долгим, то вызовется второй раз до успешного выполнения предыдущей
KG
кароч ждать не будет
🕵
да, я осознал )
V
Подскажите, как сделать обработчик, который будет периодически получать задания из БД и работать постоянно?
Я сделал такую ерунду:
Я сделал такую ерунду:
while(1) {
while (await task.next()) {
...
}
wait(60)
}
Есть более адекватный путь для этого?как по мне так это норм вариант, но вообще есть еще "серьезное" решение очередей в виде пакета bull
И
да, я осознал )
Rxjs!
KG
Rxjs!
это для умных
V
Задержка - дело уже настройки. Там задания прилетают периодически. Слишком большая задержка приводит к переполнению очереди, слишком маленькая - к пустому циклу.
Работает-то норм. Некрасиво ))
Работает-то норм. Некрасиво ))
так делай задержку только если получил 0 из очереди
🕵
Rxjs!
Увы, не знаком. Тоже посмотрю, спасибо )
KL
Rxjs!
зачем тянуть библу ради одного таймера?
V
мб ему понравится и он все на ней перепишет)
N👩
зачем тянуть библу ради одного таймера?
Чтобы с данными удобно работать было)
KL
Чтобы с данными удобно работать было)
не вижу связи
N👩
не вижу связи
Удобно с данными работать
KL
Удобно с данными работать
как связанна работа с данными с инвоуком обработки с задержкой? Есть разница, что инвоукнет функцию обработки: обзе
р вабл, колбек таймера или ивент эммитер?И
как связанна работа с данными с инвоуком обработки с задержкой? Есть разница, что инвоукнет функцию обработки: обзе
р вабл, колбек таймера или ивент эммитер?Бубубубу
И
Обзевабл
🕵
Про ивенты мне не понятно. База же сама себя не будет чекать )
🕵
но я пока не знаю как работает Rxjs. Видимо в этом корень непонимания )