RxJS 内置的 retryWhen 操作符可以帮助我们在发生错误时，进行重试操作。相比于简单地使用 retry 操作符直接重试，retryWhen 可以更加灵活地控制重试的次数和时间间隔。本文将介绍 RxJS 中的 retryWhen 操作符，包括其用法、参数和示例代码。
什么是 retryWhen 操作符？
retryWhen 操作符是一个高阶操作符，可以捕获上游 Observable 发出的错误并执行一个错误处理逻辑来决定是否要重试此 Observable。
当源 Observable 出现错误而无法继续发送项时，retryWhen 会尝试调用一个回调函数，该回调函数返回一个 Observable， retryWhen 会订阅该Observable来等待信号，以决定是否要重试源 Observable。
使用方式
retryWhen 的使用非常简单，只需要将回调函数作为参数传递即可。该回调函数应该返回一个 Observable，以便 retryWhen 可以根据这个 Observable 发出的值来判断是否要重试源 Observable。
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ---- --------- ---------- ----- - ---- -----------------
------------
------
------ -- -
----- --- --------------
---
------------------ --
------------
------------
---------------- ------ --
----- --- - - ----------------- - ---------
-
-
-
-
------------
----- ------- -- -------------------
------ ----- -- -------------------
---上述代码中，源 Observable 发出字符串 'source'，之后通过 map 操作符抛出了一个错误。此时 retryWhen 开始工作，重试过程包含以下几个步骤：
delay操作符延迟1秒钟，等待进入下一次重试。mergeMap操作符判断当前重试的次数是否大于等于2，如果是，则将错误传递给下游并结束；否则返回错误对应的 Observable，继续进行下一次重试。
注意事项
在使用 retryWhen 时，需要注意以下几点：
- 回调函数必须返回一个 Observable，否则
retryWhen则会抛出一个错误。 - 在回调函数内部定义的 Observable 需要考虑到产生无限个新值的风险。如果不这样做，可能会导致程序出现内存泄漏等问题。
- 使用
retryWhen操作符无法避免非常严重的错误情况，例如发生无限循环、发生错误源不可控等等。
结论
RxJS 中的 retryWhen 操作符可以确保我们的 Observables 在遇到错误时可以自动重试，而不需要手动撰写错误处理代码。此外，retryWhen 还可以控制重试时间和次数，以便更好地适应不同的场景。
参考代码
完整的示例代码如下：
-- -------------------- ---- -------
------ - --- ---------- - ---- -------
------ - ---- --------- ---------- ----- - ---- -----------------
------------
------
------ -- -
----- --- --------------
---
------------------ --
------------
------------
---------------- ------ --
----- --- - - ----------------- - ---------
-
-
-
-
------------
----- ------- -- -------------------
------ ----- -- -------------------
---输出结果为：
(oops delayed for 1000ms) (oops delayed for 1000ms) Error: oops
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6729e5e2ddd3a70eb6cea5ad