Retry HTTP in RXJs

retry-http.ts

function retryHttp<T>(retryCount: number, shouldRetry: (error: { code: number }) => boolean) {
  return (request$: Observable<T>): Observable<T> => request$.retryWhen(
    errors$ => errors$.flatMap(error => {
      if (shouldRetry(error)) {
        return Observable.of(true).delay(1000);
      }

      return Observable.throw({ error: 'Error cannot be retried', originalError: error });
    }).take(5)
    .concat(Observable.throw(`Request failed after ${retryCount} retries.`))
  );
}
  
// Eg:
$http.get('https://google.com').let(retryHttp(10, error => error.code === 500));