RxJS 条件发射实现：匹配数组time属性的可暂停定时器流方案咨询

之前尝试的zip、iif无法实现需求的核心原因：

zip是按流推送顺序一一配对的操作符，完全不校验数值和目标time的匹配关系，硬绑顺序的逻辑根本达不到值匹配触发的要求；iif是流初始化阶段的分支选择操作符，不是运行时对推送值做过滤映射的工具，自然无法实现动态匹配的逻辑。

核心实现思路 #

这套需求本质是对流的推送值做匹配过滤+映射转换，不需要复杂的跨流组合逻辑，直接在stream1的管道内处理即可：

• 对stream1每次推送的数值，实时判断是否存在静态数组内某个元素的time值和当前数值相等
• 把所有不匹配的推送值直接过滤丢弃
• 把匹配成功的数值，映射成对应的数组元素向外发射

参考代码实现 #

import { interval, map, filter } from 'rxjs';

// 静态配置数组
const configArray = [
  {text: "hi", time: 2},
  {text: "hi", time: 10}
];

// 可暂停的stream1：此处用interval模拟递增序列，实际可通过订阅控制实现暂停/恢复逻辑
const stream1 = interval(1000).pipe(
  map(val => val + 1) // 生成连续递增值 1,2,3...
);

// 最终触发流
const triggerStream = stream1.pipe(
  // 过滤出匹配time值的推送
  filter(currentNum => configArray.some(item => item.time === currentNum)),
  // 映射为对应的配置元素
  map(currentNum => configArray.find(item => item.time === currentNum))
);

// 订阅输出效果：当stream1推送值为2时发射对应配置，推送值为10时发射另一项配置，其余数值不触发
triggerStream.subscribe(matchedItem => console.log('触发:', matchedItem));

优化与兼容说明 #

• 当静态数组规模较大时，提前将数组转换为以time为键的Map结构，将每次遍历数组的O(n)查找降为O(1)，减少性能损耗：

// 提前构建查找表
const timeLookup = new Map(configArray.map(item => [item.time, item]));
// 管道内替换原有的数组查找逻辑
filter(currentNum => timeLookup.has(currentNum)),
map(currentNum => timeLookup.get(currentNum))

• 该实现完全兼容stream1的暂停/恢复能力：暂停期间stream1停止推送值，自然不会触发匹配判断；恢复推送后从上次中断的数值继续发送，只要推送值与配置的time值匹配，就会正常触发，不需要额外处理暂停状态的兼容逻辑。

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