如何让RxJS的next()函数传入相同数据时能第二次触发？

首先明确基础规则：RxJS 中所有原生可观察对象的 next() 方法本身没有值相等校验逻辑，只要你主动调用就会向下游推送事件。你遇到的相同值不触发的问题，几乎都是下游管道中使用了 distinctUntilChanged 这类去重操作符导致的。

针对你的需求，有以下几种可行方案：

• 移除/调整去重操作符
  直接删除下游管道中的 distinctUntilChanged 操作符，即可让所有 next() 调用都触发订阅回调。
  如果需要保留部分场景的去重能力，可以自定义 distinctUntilChanged 的对比函数：

  source$.pipe(
    distinctUntilChanged((prev, curr) => {
      // 所有场景都强制不判定为相等，所有next都会下发
      return false;
      // 也可以自定义规则，比如只有forceEmit为true时强制下发
      // return prev.id === curr.id && !curr.forceEmit;
    })
  )
  

• 传入新引用的对象
  distinctUntilChanged 默认使用引用对比判断值是否相等，如果你要传的是对象类型，每次 next() 时传入新的实例即可绕过去重：

  const data = {name: 'demo', age: 20};
  // 错误写法：两次传同一个引用，会被默认去重逻辑过滤
  subject.next(data);
  subject.next(data);
  
  // 正确写法：每次解构生成新对象，引用不同可以正常触发
  subject.next({...data});
  subject.next({...data});
  

• 使用无状态通知流
  如果你的需求只是触发事件通知，不需要传递实际业务数据，可以直接用 Subject<void> 作为通知流，直接调用无参数的 next() 即可，不需要关心值重复问题：

  const notify$ = new Subject<void>();
  // 多次调用都会正常触发下游
  notify$.next();
  notify$.next();
  

如果不需要缓存上一次的状态值，也可以把 BehaviorSubject/ReplaySubject 替换为普通 Subject，普通 Subject 不会缓存历史值，自然不存在重复值过滤的问题。

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