Convert array of observables of observables to array of observables rxjs

Question

To simplify the problem i have used numbers and strings here. The code:

const numbers$:Observable<number[]> = of([1,2,3]);
const strings: string[] = ["a","b"];

function getStrings(): Observable<string>[]{
   return numbers$.pipe( 
     map((numbers: number[]) => {
       const strings$: Observable<string>[] =  strings.map(s => of(s));
       return strings$;
     }),
  )
}

getStrings().subscribe(x => console.log(x))

The error i am getting is: Type 'Observable<Observable<string>[]>' is missing the following properties from type 'Observable<string>[] How can i get Observable<string>[] from getStrings function? I have tried to use flatMap, switchMap but unable to get the perfect combination.

Stackblitz

Using Observable<string>[] means an array of Observable<string> which is not what you're returning right now. Maybe you wanted this instead Observable<string[]>? — martin
– martin, Commented Mar 19, 2020 at 15:23
No i want Observable<string>[] because in my application i will use this in forkJoin — Aamir
– Aamir, Commented Mar 19, 2020 at 15:28
@martin You are right, i want Observable<string[]>, not Observable<string>[] — Aamir
– Aamir, Commented Mar 19, 2020 at 15:31

martin · Accepted Answer · 2020-03-19 15:55:02Z

1

You'll need to use mergeMap() and forkJoin():

function getStrings(): Observable<string[]>{
   return numbers$.pipe( 
     mergeMap((numbers: number[]) => {
       const strings$: Observable<string>[] =  strings.map(s => of(s));
       return forkJoin(strings$);
     }),
  )
}

getStrings().subscribe(x => console.log(x))

https://stackblitz.com/edit/rxjs-dzvsbh?file=index.ts

answered Mar 19, 2020 at 15:55

martin

97.4k26 gold badges205 silver badges237 bronze badges

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

Comments

CaspianTerrazzo · Accepted Answer · 2020-03-19 15:47:42Z

0

So as I understand you want to "zip" two lists together, via observable ?

I can offer you this one


    const numbers$: Observable<number[]> = of([1, 2, 3]);
    const strings$: Observable<string[]> = of(['a', 'b']);

    const combined$: Observable<any> = zip(numbers$, strings$)
      .pipe(
        map(([numbers, strings]) =>
          numbers.length > strings.length ?
            numbers.map((value, index) => [value, strings[index]]) :
            strings.map((value, index) => [numbers[index], value]))
      );

    combined$.subscribe(value => console.log(value));

This will log: [ [ 1, "a" ], [ 2, "b" ], [ 3, null ] ]

answered Mar 19, 2020 at 15:47

CaspianTerrazzo

2,15815 silver badges29 bronze badges

2 Comments

Aamir Over a year ago

Basically no, because in real example strings$ is dependent on numbers$ response.

CaspianTerrazzo Over a year ago

@Aamir ok, sorry for misunderstanding :)

Collectives™ on Stack Overflow

Convert array of observables of observables to array of observables rxjs

2 Answers 2

Comments

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related