RxJS Observable：使用计数重试，然后使用通知程序

Question

首先，我想用一个简单的计数重试：

• 重试源 observable n 次。
• 然后，发出错误。

（最好在每次重试后立即发出错误，但retry(count) 似乎没有这样做。）

如果我理解正确的话，这是retry(count)的行为：

{
  new Rx.Observable(observer => {
    console.log("subscribe");
    observer.error("ERROR");
  })
    .retry(3)
    .subscribe({
      error: console.log
    });
}
// subscribe
// subscribe
// subscribe
// subscribe
// ERROR

然后，我想允许用户手动重试。当一个重试通知 observable (retry$) 发出时，再次重试 observable，之后每次都发出错误。

我尝试为此使用retryWhen，但是尽管确实发生了重试，但从未发出错误。

我想重试但也发出任何错误，以便在重试运行时在用户界面中显示它们。

{
  const retrySubject = new Rx.Subject();
  const retry$ = retrySubject.asObservable();
  new Rx.Observable(observer => {
    console.log("subscribe");
    observer.error("ERROR");
  })
    .retryWhen(() => retry$)
    .subscribe({
      error: console.log
    });
  retrySubject.next();
}
// subscribe
// subscribe

此外，我不确定如何将其与retry(count) 结合使用。如果我链接重试运算符，它们会相互触发。

Answer 1

retryWhen 提供错误流 - 您可以查看错误流并在 3 次发射后忽略它，然后仅在用户触发时重试。

const retrySubject = new Rx.Subject();
const retry$ = retrySubject.asObservable();
new Rx.Observable(observer => {
  console.log("subscribe");
  observer.error("ERROR");
})
  .retryWhen(errors => Rx.Observable.merge(
    errors
      .do(error => console.log(error)) // log error
      .filter((error, index) => index < 3), // take only first 3 and ignore the rest
    retry$ // also retry with user request
  ))
  .subscribe();

retrySubject.next();

您可以使用take(3) 代替filter，但这会停止errors 流，因此错误记录也会停止。 filter 运营商将使其保持“运行”。