如何消除RxJS中重复订阅回调代码的反模式？

针对你遇到的重复代码问题，可以通过先统一获取目标Observable，再集中处理结果的方式消除冗余，具体有两种常用实现方式：

方式一：三元表达式简化分支（适合二元条件） #

直接通过条件判断选择对应的异步函数，得到Observable后统一订阅，把commonCode只写一次：

// 先根据条件确定要调用的异步Observable
const targetObservable = condition1 ? asyncFun1() : asyncFun2();

// 统一订阅并处理结果，commonCode只写一次
targetObservable.subscribe((result) => {
  // 这里写你的commonCode，正常依赖result即可
});

方式二：抽离分支逻辑为函数（适合多条件场景） #

如果后续条件增多，把选择Observable的逻辑单独抽成函数，再统一订阅：

// 抽离分支判断逻辑
function getTargetObservable() {
  if (condition1) {
    return asyncFun1();
  } else if (condition2) { // 可扩展更多条件
    return asyncFun2();
  } else {
    return asyncFun3(); // 默认情况
  }
}

// 统一处理结果
getTargetObservable().subscribe((result) => {
  // 这里写你的commonCode
});

这两种方式都能让分支选择逻辑和结果处理逻辑分离，既消除了重复代码，也让代码结构更清晰，同时完全保留commonCode对result的依赖。

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