Для каждого испускаемого значения я хочу выполнить некоторую асинхронную обработку.
Моя цель - подождать перед принятием следующего значения, пока myPromise не будет разрешено.
events.pipe(awaitPromise(async event => await myPromise(event))).subscribe();
Примечания:
- Я не знаю, сколько времени потребуется для выполнения обещания
- Значения, выданные во время «паузы», не должны отбрасываться
Я не совсем уверен, возможно ли это вообще с Rx Js. Может мне нужно внедрить какую-то другую систему "очередей"? Но мне было бы очень удобно сделать это с Rx Js!