RxJS重复查询实现：从350条记录中随机选5条满足total总和小于30的方案

首先纠正两个常见的认知偏差：

• 你对takeUntil的功能存在误解：这个操作符的作用是收到外部流的通知后立刻终止当前订阅，完全不支持「根据内部计算结果判断要不要循环重试」的场景，硬套它反而会把逻辑搞复杂。
• expand确实是这个场景下最适配的操作符：它天生支持「上一次的输出当下一次的输入，递归执行直到满足退出条件」的流程，要跟踪total总和根本不需要额外维护全局状态，每轮循环把计算结果作为上下文透传即可。

你现有代码除了操作符选型不对，还有个小bug：原来的随机排序写法products.sort(() => (Math.random() - Math.random()))既存在随机分布不均匀的问题，还会直接修改原数组引用引发不必要的变更检测。下面是修正后的可直接运行的完整逻辑：

products$ = combineLatest([
  this._productService.robots$,
  this.refreshProductAction$
]).pipe(
  // 切到最新数据源，自动终止上一轮未完成的无效筛选
  switchMap(([products]) => {
    // expand初始值：传入全量商品池作为基础数据源
    return of(products).pipe(
      expand((productPool) => {
        // 用Fisher-Yates算法做真随机洗牌，替代原有的不靠谱sort写法
        const shuffledPool = [...productPool];
        for (let i = shuffledPool.length - 1; i > 0; i--) {
          const swapIdx = Math.floor(Math.random() * (i + 1));
          [shuffledPool[i], shuffledPool[swapIdx]] = [shuffledPool[swapIdx], shuffledPool[i]];
        }
        // 取前5条记录
        const pickedList = shuffledPool.slice(0, 5);
        // 计算当前选中列表的total总和
        const totalSum = pickedList.reduce((sum, item) => sum + item.total, 0);

        if (totalSum < 30) {
          // 把最终结果带终值标记返回
          return of({
            isFinal: true,
            value: pickedList
          });
        }
        // 不满足要求：把原商品池作为下一轮的输入，触发重新随机，标记为中间态
        return of({
          isFinal: false,
          value: productPool
        });
      }),
      // 过滤掉所有中间循环态，只保留最终满足条件的结果
      filter(res => res.isFinal),
      // 取出最终的5条记录
      map(res => res.value),
      // 拿到第一个符合要求的结果后，终止无限循环
      take(1)
    )
  })
)

• 整个循环流程完全自闭合：不需要手动触发刷新事件，只要某一轮随机选出的5条记录total总和不满足要求，expand会自动基于同一个全量商品池重新跑一次随机选取的流程。
• 状态跟踪零成本：每轮循环计算的total总和只存在于当前递归流程内，不需要额外声明全局变量或者中间状态，不会和其他流产生副作用冲突。
• 可以按业务需求加安全兜底：如果怕出现「所有5条组合的total都超过30」的极端情况导致无限循环，可以在expand的上下文里加个重试计数，累计循环到比如1000次还没满足条件就直接退出流程，返回兜底值。

内容的提问来源于stack exchange，提问作者Jose R. Chacón