RxJS中iif条件运算符冗长写法的简化方案咨询

你当前的写法冗余主要来自三点：重复包装of(x)、同步场景下滥用iif、同步转换场景不必要地使用mergeMap做高阶Observable映射，以下是不同场景下的简化写法：

方案1：最简洁写法（推荐，同步转换场景） #

如果你的逻辑是纯同步值转换，完全可以移除mergeMap、iif、of这些仅处理异步流的API，只用单个map就可以完成逻辑，代码量减少70%以上：

import { timer, take, map } from 'rxjs'

timer(0, 1000).pipe(
  take(4),
  map(x => x <= 1 ? x * 2 : x * 3)
).subscribe(x => {
  console.log('output', x)
})

运行结果和你给出的预期输出完全一致。

方案2：保留抽离的操作符 #

如果你需要保留抽离的double()、triple()操作符供其他地方复用，不需要使用iif，只需要把公共的of(x)提到外层，用三元表达式选择要挂载的操作符即可：

import { timer, take, pipe, map, mergeMap, of } from 'rxjs'

const double = () => pipe(map((x: number) => x * 2))
const triple = () => pipe(map((x: number) => x * 3))

timer(0, 1000).pipe(
  take(4),
  mergeMap(x => of(x).pipe(x <= 1 ? double() : triple()))
).subscribe(x => {
  console.log('output', x)
})

这种写法和你原代码逻辑100%一致，没有冗余的重复包装。

方案3：适配后续异步分支场景 #

如果后续你两个分支的逻辑会替换成HTTP请求、定时器等异步Observable，必须保留高阶流映射能力，也可以简化iif的写法，去掉重复的of(x).pipe()包装：

// 保留抽离操作符的写法
mergeMap(x => iif(
  () => x <= 1,
  of(x).pipe(double()),
  of(x).pipe(triple())
))

// 逻辑简单时直接写值，进一步精简
mergeMap(x => iif(() => x <=1, of(x*2), of(x*3)))

注意：iif的核心价值是懒创建Observable，如果两个分支的Observable创建成本很高（比如包含复杂的异步逻辑、需要提前申请资源），用iif才会有收益，纯同步判断场景下直接用三元表达式即可，不需要额外引入iif。

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