rxjs pass forkjoin a function which return a array of observables

Question

I have a function which returns an array of Observables

function getMultipleObservables() {
    let coordinationObservables: Observable<any>[] = [];
    coordinationObservables.push(Observable.of([1,2,3,4]))
    coordinationObservables.push(Observable.of([1,2,3,4]))
    return coordinationObservables
}

I have another part of code chains multiple observables like this:

this.someService.flatMap(()=>{
    return Observable.forkJoin((getMultipleObservables())=>{
        //handle the responses
    })
}).subscribe(()=>{

})

So my question is how could I properly pass a function as a parameter to the forkJoin, and handle it in the callback function.

Ashish Ranjan · Accepted Answer · 2019-01-08 01:32:00Z

2

Use the spread operator.

return Observable.forkJoin(...getMultipleObservables()).map((data) => {
     // do something, write your code here
     // later subscribe it wherever it is returning
     // using map() like this is works for rxjs < 5.5,
     // use it under pipe() if you have a higher version
     // like: forkjoin(...getMultipleObservables()).pipe(map());
     return modifiedData // if modified, else no need to add map
})

edited Jan 8, 2019 at 1:32

answered Jan 8, 2019 at 1:25

Ashish Ranjan

13k5 gold badges32 silver badges53 bronze badges

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

Collectives™ on Stack Overflow

rxjs pass forkjoin a function which return a array of observables

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related