@thekiba Привет , мб ты сможешь подсказать разбил массив на поток событий с помощью mergeMap , а как его обратно склеить в него , toArray не сработает , только если в связки с take
source — твой поток с массивами, один эмит — один массив
source.pipe( switchMap((myArray) => combineLatest(myArray.map(p => а тут приводишь каждый элемент к observable))) )