Вопрос для сверхразумов в асинхронности 😁 Работаю с биржей, получаю из

Question

Вопрос для сверхразумов в асинхронности 😁 Работаю с биржей, получаю из

flow ивенты об изменении одного элемента массива нужных orders.

Нужно сделать копию этого массива и отправить на обработку.

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

Думаю между ними сделать очередь, куда producer будет складывать изменения, а consumer будет обрабатывать их.

Важный момент: изменения приходят не обо всем массиве сразу, а только об одном элементе, то есть нужно где-то сохранить массив и создавать его измененную копию, чтобы передать в consumer.

Как это можно сделать?

Есть идея оставлять в очереди минимум один элемент, даже если он обработан, но все равно mutable data имеет место :(