I'm currently trying to process HTTP Post requests in sequence, additionally trying to repeat each failed request until it succeeds (that is a requirement) and then and only then to continue with processing other requests. My code looks like this for now (it not working as it should, retryWhen is not used properly, I am aware of that, it's used just as a starting point reference):
...
subject
.pipe(
concatMap(async request => await this._sendPostRequest(request)),
retryWhen(errors =>
errors.pipe(
tap(error => this._logger.error('error sending request', error)),
delayWhen(() => timer(5000))
)
)
)
.subscribe();
...
You're close!
Just attach your retry to the promise rather than the concatenated stream as a whole.
subject.pipe(
concatMap(request => defer(() => sendPostRequest(request)).pipe(
retryWhen(error$ => error$.pipe(
tap((error) => console.warn('error sending request', error)),
delay(1000)
))
))
).subscribe();