Обрабатывать сообщения отправителя событий последовательно

Question

myEmitter.on('data', handleData).

Как я могу handleData вызываться последовательно, а не параллельно?

Например: n data сообщения приходят сгруппированы очень близко друг к другу во времени, и я хочу, чтобы они обрабатывались в порядок последовательно , никогда не параллельно.

Можно ли легко добиться этого с какой-нибудь библиотекой?

примечание: handleData asyn c

Answer 1

Если у вас есть дополнительное событие, например end, вы сможете хранить каждый элемент данных в массиве в порядке их поступления. После получения события end вы можете последовательно обрабатывать ранее сохраненную очередь данных.

Пример:

const dataQueue = [];
myEmitter.on('data', data => dataQueue.push(data));
myEmitter.on('end', () => dataQueue.forEach(handleData));

Однако вы не сможете начать обработку до того, как все данные прибыли.