RxJS中触发父级catchError后如何让Observable继续发射值

RxJS 流遵循核心错误传播规则：一旦流中出现未被捕获的错误，整个流会立即终止，所有订阅自动取消。
你当前代码的问题在于：当错误被parent的catchError捕获处理后，返回的of('err')发射完值就会结束整个流，iWillContinueListening$对应的点击事件监听也会被同步取消，后续点击自然不会触发任何逻辑。

仅需在parent的管道中，catchError操作符之后新增repeat操作符即可。repeat的作用是当上游流正常结束后，自动重新订阅上游的iWillContinueListening$，恢复点击事件的监听能力。

修改后的核心代码如下：

const parent = iWillContinueListening$.pipe(
  catchError((err) => {
    console.log('er', err);
    return of('err');
  }),
  repeat() // 新增此行即可实现需求
);

修改后完整执行流程如下：

• 点击按钮触发请求，fakeRequest$抛出错误
• 错误冒泡到parent的catchError，正常触发父层错误处理逻辑，返回of('err')并打印错误值
• of('err')值发射完成后，repeat自动重新订阅iWillContinueListening$，点击事件监听恢复
• 后续点击可以正常触发请求逻辑，同时父层错误处理逻辑也会在每次出错时正常执行

内容的提问来源于stack exchange，提问作者user3132974