Angular7中RxJS Reduce未执行问题排查求助

你的问题核心在于reduce操作符从未执行，因为整个上游Observable流没有触发complete事件——而reduce必须等到流完全结束才会输出累加结果。

为什么会这样？ #

我们一步步拆解你的流：

1. actions$.pipe(ofType(...), take(1))：这部分是正常的，take(1)会取第一个LoadInstances动作后立刻完成，没问题。
2. switchMap(() => this.entityService.GetInstances())：这里是关键！如果GetInstances()返回的Observable没有完成（比如是自定义Observable忘记调用complete()，或者是BehaviorSubject这类持续流），那么switchMap会一直保持对这个流的订阅，等待它的下一个值——哪怕内部的from(instances)已经把所有实例都发射完并完成了，整个上游流还是处于“活跃”状态，不会触发complete。
3. 后续的flatMap处理每个实例的请求都是单值HTTP流（会自动完成），所以你能看到before reduce的tap执行3次，但因为最上游的GetInstances()流没完成，整个链永远不会触发complete，reduce自然不会执行。

验证方法 #

你可以先验证GetInstances()是否真的没完成：

// 在某个地方临时订阅，看complete回调是否执行
this.entityService.GetInstances().subscribe(
  instances => console.log('实例数组:', instances),
  err => console.error('请求错误:', err),
  () => console.log('GetInstances 流已完成！')
);

如果最后一行日志没出现，就坐实了GetInstances()的流没完成。

解决办法 #

有两种简单的修复方式：

1. 让GetInstances()返回的流自动完成：

   • 如果是你自定义的Observable，确保在发出数组后调用observer.complete()：

     GetInstances(): Observable<Instance[]> {
       return new Observable(observer => {
         // 模拟获取数据
         const instances = [/* 你的实例数据 */];
         observer.next(instances);
         observer.complete(); // 必须加这一行！
       });
     }
     

   • 如果是用HttpClient请求的，默认会自动完成，这一步可以跳过。

2. 强制截断GetInstances()的流：
   如果你不想修改entityService的实现，直接在switchMap里给GetInstances()加上take(1)，强制它取第一个值后完成：

   switchMap((action: fromAppAction.LoadInstances) => this.entityService.GetInstances().pipe(take(1)) ),
   

这样修改后，整个流会在所有实例处理完成后触发complete，reduce就会把所有结果合并成数组，最后的tap也会正常输出日志了。

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