如何在RxJS中实现双Subject的双双更新后合并逻辑？

你要实现的逻辑正好契合RxJS zip操作符的核心行为：

• 首次需两个Subject都发射过值，才会组合它们的首个值发射；
• 后续必须两个Subject各自至少再发射一次新值，才会组合双方的下一组值发射；
• 该逻辑会持续到其中一个Subject完成。

代码示例 #

import { Subject, zip, map } from 'rxjs';

// 初始化两个Subject
const num$ = new Subject<number>();
const char$ = new Subject<string>();

// 构建配对Observable
const pairedOutput$ = zip(num$, char$).pipe(
  map(([num, char]) => `${num}${char}`)
);

// 订阅查看输出
pairedOutput$.subscribe(console.log);

// 模拟你给出的发射序列
num$.next(1);
char$.next('a'); // 输出: 1a
num$.next(2);
num$.next(3);
num$.next(4);
char$.next('b'); // 输出: 2b
char$.next('c'); // 输出: 3c
num$.next(5);
num$.next(6);
char$.next('d'); // 输出: 4d

匹配验证 #

对应你提供的发射序列：

• 数字Subject：1 → 2 → 3 → 4 → 5 → 6
• 字符Subject：a → b → c → d

最终输出完全符合你的预期：1a → 2b → 3c → 4d。

如果后续需要更灵活的组合规则（比如允许复用某一方的最新值但要求双方都有更新动作），可以基于combineLatest结合过滤逻辑实现，但当前需求用zip是最简洁的方案。

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