Architecting Angular Applications with Redux, RxJS, and NgRx

Advanced Retry

What we most likely want is to combine the delay between retry attempts with being able to specify how many times we want to retry the stream. Let's have a look at how we can accomplish that:

// error-handling/error-retry-advanced.jsconst Rx = require("rxjs/Rx");let ajaxStream$ = Rx.Observable.ajax("UK1.json")  .do(r => console.log("emitted"))  .map(r => r.response)  .retryWhen(err => {    return err    .delay(3000)    .take(3);});

The interesting part here is that we use the operator .take(). We specify the number of emitted values we want from this inner Observable. We have now accomplished a nice approach in which we are able to control the number of retries and the delay between retries. There is an aspect to this that we haven't tried, ...