按序列收集发射值：A先发射后B发射才收集两者值的实现方案

你可以组合使用switchMap和take(1)操作符实现需求，无需两个observable提前完成，逻辑完全匹配你的收集规则：

• 每次observable A发射新值时，通过switchMap切换到对observable B的监听
• 用take(1)指定仅取B在A本次发射之后的第一个值，之后自动结束本次对B的监听
• 若A在B未发射值时就发出新值，switchMap会自动取消上一次对B的监听，以最新的A值为准等待后续B值

代码示例（RxJS） #

import { switchMap, take, map } from 'rxjs';

const pairedValue$ = A.pipe(
  switchMap(aVal => B.pipe(
    take(1),
    map(bVal => [aVal, bVal] as const)
  ))
);

// 订阅使用
pairedValue$.subscribe(([a, b]) => {
  // 此处可拿到符合规则的配对值
  console.log('收集到配对值：', a, b);
});

边界场景适配 #

• 如果你需要保留所有A的发射值，按A的发射顺序依次匹配后续的B值，把上述代码中的switchMap替换为concatMap即可
• B发射频率高于A的场景下，仅A更新后第一个B值会被捕获，其余B值自动忽略，完全符合你的收集规则

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