Angular - RxJs ForkJoin How To Continue Multiple Requests Even After A Error

Question

I am querying a single API endpoint multiple times except with different parameters. For what ever reason some of these requests may fail and return a 500 error. If they do i still want the other requests to carry on and return me the data of all the successfull requests.

let terms = [];
terms.push(this.category.category);
terms = terms.concat(this.category.interests.map((x) => x.category));

for (let i = 0; i < terms.length; i++) {

    const params = {
        term: terms[i],
        mode: 'ByInterest'
    };


    const request = this.evidenceService.get(this.job.job_id, params).map((res) => res.interactions);

    this.requests.push(request);

}

const combined = Observable.forkJoin(this.requests);

combined.subscribe((res) => {
    this.interactions = res;
});

martin · Accepted Answer · 2018-05-02 08:50:20Z

11

Most easily chain each request with catch that emits just null:

const request = this.evidenceService.get(...)
  .map(...)
  .catch(error => Observable.of(null)); // Or whatever you want here

The failed requests will have just null value in the resulting array that will be emitted by forkJoin.

Note that you can't use Observable.empty() in this situation because empty() doesn't emit anything and just completes while forkJoin requires all source Observables to emit at least one value.

answered May 2, 2018 at 8:50

martin

97.4k26 gold badges205 silver badges237 bronze badges

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

1 Comment

Guntram Over a year ago

See "catchError" in other answer stackoverflow.com/a/50130670/745931 for the "newer" rxjs version, where you have to use pipe() instead of chaining...

ibenjelloun · Accepted Answer · 2018-05-02 08:53:32Z

5

You could use rxjs catchError :

const request = this.evidenceService.get(this.job.job_id, params)
.pipe(map((res) => res.interactions),
catchError(error => of(undefined)));

answered May 2, 2018 at 8:53

ibenjelloun

7,7732 gold badges34 silver badges55 bronze badges

Collectives™ on Stack Overflow

Angular - RxJs ForkJoin How To Continue Multiple Requests Even After A Error

2 Answers 2

1 Comment

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related