rxjs concatMap with array

Question

There is Higher Order Observable observable

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);

How to use concatMap in order to as soon as the previous observable is completed, the next one immediately begins. After it will return result array of Observable.Need to use concatMap.

martin · Accepted Answer · 2019-03-20 20:51:16Z

3

You'll need to use toArray() to collect all emissions from all source Observables.

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

answered Mar 20, 2019 at 20:51

martin

97.4k26 gold badges205 silver badges237 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

Andrei Over a year ago

calling concatAll() instead of concatMap(observable => observable) seems prettier

martin Over a year ago

Yes, but OP said he needs to use concatMap.

Collectives™ on Stack Overflow

rxjs concatMap with array

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related