rxjs concatMap с массивом

Question

Наблюдаемые наблюдаемые высшего порядка

const obs1 = interval(1000).pipe(take(5));
const obs2 = interval(500).pipe(take(2));
const obs3 = interval(2000).pipe(take(1));
//emit three observables
const source = of(obs1, obs2, obs3);

Как использовать concatMap для того, чтобы, как только предыдущая наблюдаемая была завершена, немедленно начинается следующая. После этого он вернет массив результатов Observable.Need для использования concatMap.

Answer 1

Вам необходимо будет использовать toArray() для сбора всех выбросов из всех исходных наблюдаемых.

source.pipe(
  concatMap(observable => observable),
  toArray(),
);