如何基于Observable类型属性的最新值过滤Observable<Notice[]>流并输出符合条件的Notice数组？

你的核心需求是：每当外部的Notice[]数组更新，或者任何Notice的isVisible$状态变化时，一次性发射当前所有符合条件的完整数组，而不是每次单个状态变化就发射一次累加后的数组。现有代码用scan累加的方式确实会导致频繁发射，因为每个isVisible$的变化都会触发一次数组更新并发射，而不是等待所有当前Notice的状态都就绪后再发射完整结果。

优化后的实现代码 #

notices.pipe(
  switchMap(currentNotices => {
    // 将每个Notice转换为包含其最新isVisible状态的流
    const noticeVisibilityStreams = currentNotices.map(notice => 
      notice.isVisible$.pipe(
        // 始终关联对应的Notice对象，方便后续组合
        map(isVisible => ({ notice, isVisible })),
        // 确保即使isVisible$没有新变化，也能保留当前状态（如果isVisible$保证至少发射一次，可省略startWith）
        startWith({ notice, isVisible: false })
      )
    );

    // 使用combineLatest组合所有Notice的状态流：任何一个状态变化时，都会得到所有Notice的最新状态
    return combineLatest(noticeVisibilityStreams).pipe(
      // 过滤出isVisible为true的Notice，组成数组
      map(visibilityStates => 
        visibilityStates
          .filter(({ isVisible }) => isVisible)
          .map(({ notice }) => notice)
      )
    );
  })
);

代码解释 #

1. switchMap处理外部数组更新：每当外部的notices数组发射新值时，switchMap会取消之前订阅的内部状态流，重新为新的Notice数组创建状态流组合，完全符合你“新数组发射时重新执行过滤逻辑”的需求。
2. 单个Notice的状态流转换：把每个Notice转换成一个持续发射{ notice, isVisible }的流，确保我们能跟踪每个Notice的最新可见状态。如果你的isVisible$确实保证至少发射一次，startWith可以省略；如果需要初始默认状态，可保留该配置。
3. combineLatest组合所有状态：这个操作符会在任何一个内部状态流更新时，将所有Notice的最新状态汇总成一个完整快照。这正是你需要的：不管是哪个Notice的可见性变化，都能得到当前所有Notice的状态全貌。
4. 一次性过滤并生成结果数组：每次combineLatest发射状态快照时，我们直接过滤出可见的Notice，生成完整的结果数组并发射。这样就不会出现频繁的部分数组发射，而是每次都发射完整的符合条件的数组。

对比现有代码的问题 #

你的原有代码用mergeMap+scan的方式，本质是逐个处理每个Notice的状态变化，每次变化都往数组里累加（或尝试去重），这就导致每个单个状态变化都会触发一次数组发射。而用combineLatest的方式，我们始终基于所有Notice的最新状态快照来生成结果数组，只会在状态变化时发射一次完整数组，完全解决了频繁发射的问题。

内容的提问来源于stack exchange，提问作者marked-down