Comment créer un RxJS Retywhen avec delay et limit sur tries

vous devez appliquer la limite au signal de Ré-essai, par exemple si vous ne vouliez que 10 ré-essais:

loadSomething(): Observable<SomeInterface> {
  return this.http.get(this.someEndpoint, commonHttpHeaders())
    .retryWhen(errors => 
      // Time shift the retry
      errors.delay(500)
            // Only take 10 items
            .take(10)
            // Throw an exception to signal that the error needs to be propagated
            .concat(Rx.Observable.throw(new Error('Retry limit exceeded!'))
    );
}

EDIT

certains des commentateurs ont demandé comment s'assurer que la dernière erreur est celle qui est lancée. La réponse est un peu moins nette mais pas moins puissante, il suffit d'utiliser l'un des opérateurs de carte aplati (concatMap, mergeMap, switchMap) pour vérifier à quel index vous êtes.

Remarque: l'Utilisation de la nouvelle RxJS 6 pipe syntaxe pour l'avenir correction d'épreuves (également disponible dans les versions ultérieures de RxJS 5).

loadSomething(): Observable<SomeInterface> {
  const retryPipeline = 
    // Still using retryWhen to handle errors
    retryWhen(errors => errors.pipe(
      // Use concat map to keep the errors in order and make sure they
      // aren't executed in parallel
      concatMap((e, i) => 
        // Executes a conditional Observable depending on the result
        // of the first argument
        iif(
          () => i > 10,
          // If the condition is true we throw the error (the last error)
          throwError(e),
          // Otherwise we pipe this back into our stream and delay the retry
          of(e).pipe(delay(500)) 
        )
      ) 

  return this.http.get(this.someEndpoint, commonHttpHeaders())
    // With the new syntax you can now share this pipeline between uses
    .pipe(retryPipeline)
}