Народ, подскажите как задачу решить.
Приходят данные, есть асинхронная функция, которая эти данные обрабатывает.
Данные приходят каждую секунду. Обработка 1 или нескольких данных занимает примерно одинаковое время. Но важно, чтобы они процессились последовательно.
Если за секунду данное не удалось процесснуть, и уже пришло следующее, то я не хотел бы запускать процессор, подождать следующего данного, и процесснуть сразу 2.
Соответственно, если не успел процесснуть штук 5-10, то потом накопившиеся данные процессим сразу пачкой.
Короче, нужен такой буферизатор перед асинхронной функцией.
Я могу сам нагородить огород, но мб в каком-то rx / стримах / еще где есть готовая штука для таких сценариев?