RxJS

Question

我目前正在尝试按顺序处理 HTTP Post 请求，另外尝试重复每个失败的请求直到成功（这是一项要求），然后才继续处理其他请求。我的代码现在看起来像这样（它不能正常工作，retryWhen 没有正确使用，我知道，它只是作为一个起点参考）：

...
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();
...

我们非常欢迎任何帮助和指南。谢谢

Answer 1

你很接近！

只需将重试附加到 promise 而不是整个串联流。

subject.pipe(     
  concatMap(request => defer(() => sendPostRequest(request)).pipe(           
    retryWhen(error$ => error$.pipe(               
      tap((error) => console.warn('error sending request', error)),               
      delay(1000)             
    ))         
  ))
).subscribe();

RxJS - 按顺序处理 HTTP 请求

RxJS - Processing HTTPrequests in sequence

javascript