Народ, подскажите как задачу решить.

Приходят данные, есть асинхронная функция, которая эти данные обрабатывает.

Данные приходят каждую секунду. Обработка 1 или нескольких данных занимает примерно одинаковое время. Но важно, чтобы они процессились последовательно.

Если за секунду данное не удалось процесснуть, и уже пришло следующее, то я не хотел бы запускать процессор, подождать следующего данного, и процесснуть сразу 2.

Соответственно, если не успел процесснуть штук 5-10, то потом накопившиеся данные процессим сразу пачкой.

Короче, нужен такой буферизатор перед асинхронной функцией.

Я могу сам нагородить огород, но мб в каком-то rx / стримах / еще где есть готовая штука для таких сценариев?

не совсем. Этот по времени буферизирует, а мне по выполнению процессинга

Народ, подскажите как задачу решить.

Приходят данные, есть асинхронная функция, которая эти данные обрабатывает.

Данные приходят каждую секунду. Обработка 1 или нескольких данных занимает примерно одинаковое время. Но важно, чтобы они процессились последовательно.

Если за секунду данное не удалось процесснуть, и уже пришло следующее, то я не хотел бы запускать процессор, подождать следующего данного, и процесснуть сразу 2.

Соответственно, если не успел процесснуть штук 5-10, то потом накопившиеся данные процессим сразу пачкой.

Короче, нужен такой буферизатор перед асинхронной функцией.

Я могу сам нагородить огород, но мб в каком-то rx / стримах / еще где есть готовая штука для таких сценариев?

takeLatest saga?

Я хз что это

Народ, подскажите как задачу решить.

Приходят данные, есть асинхронная функция, которая эти данные обрабатывает.

Данные приходят каждую секунду. Обработка 1 или нескольких данных занимает примерно одинаковое время. Но важно, чтобы они процессились последовательно.

Если за секунду данное не удалось процесснуть, и уже пришло следующее, то я не хотел бы запускать процессор, подождать следующего данного, и процесснуть сразу 2.

Соответственно, если не успел процесснуть штук 5-10, то потом накопившиеся данные процессим сразу пачкой.

Короче, нужен такой буферизатор перед асинхронной функцией.

Я могу сам нагородить огород, но мб в каком-то rx / стримах / еще где есть готовая штука для таких сценариев?

что-то вроде debounce/throttle но с накоплением данных?

я аж икнул