RxJS中ReplaySubject使用defaultIfEmpty操作符无预期输出问题排查

defaultIfEmpty 运算符的触发规则是仅当上游Observable正常触发complete完结信号，且整个生命周期内没有发射过任何next值时，才会向下游发射你指定的默认值。
你现有代码中的ReplaySubject从未调用complete()方法，整个流始终处于活跃可发射状态，defaultIfEmpty无法判定后续是否会有新值发射，因此永远不会触发默认值逻辑，也不会有任何输出到控制台。

根据不同业务场景可选择对应处理方式：

• 场景1：确定该Subject不需要再发射任何值，直接手动触发完结
  只需要在合适的位置调用subject.complete()即可，示例代码：

  const subject = new ReplaySubject<string>();
  const observable$ = subject.asObservable();
  const result = observable$.pipe(
    map(value => value + 'not empty'),
    defaultIfEmpty('empty')
  );
  result.subscribe(value => console.log(value));
  // 手动调用完结，触发defaultIfEmpty逻辑
  subject.complete();
  

  运行后控制台会正常输出empty。

• 场景2：希望订阅时如果Subject当前无缓存值就立即返回默认值，不需要等待流完结
  可以结合take、timeout等运算符实现需求，示例：

  // 超过3秒没有返回值则默认返回empty
  const result = observable$.pipe(
    take(1),
    map(value => value + 'not empty'),
    timeout({first: 3000, with: () => of('empty')})
  );
  

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