为什么多次向concat()传入同一个Observable会触发重放逻辑？

如果你向concat多次传入同一个Observable，其值流会在每次订阅时被“重放”，这意味着你可以按需重复指定Observable任意次数。如果觉得向concat传入1000次同一个Observable过于繁琐，你可以直接使用repeat操作符。

核心设计逻辑 #

这个表现本质是RxJS Observable的基础特性和concat的固有执行规则共同决定的，完全符合concat的常规行为逻辑：

• 常规创建的冷Observable（如of、from生成的实例）本质是流执行逻辑的描述模板，本身不保存执行状态。每次发起新的订阅都会独立重新执行整个流的逻辑，上一次订阅结束的状态不会影响下一次订阅，这是RxJS的底层默认设计，和是否使用concat无关。
• concat的核心执行逻辑只有一条：按传入顺序依次订阅每个Observable，等待当前订阅的流complete后，再触发下一个Observable的订阅。它不会额外校验当前要订阅的Observable是否和之前的是同一个引用、是否曾经被订阅过，只是按规则依次触发订阅即可。

你之前的预期偏差，本质是把Observable当成了「已经运行完成的结果容器」，但普通的冷Observable本身不承载运行结果，只定义运行规则，每次订阅都是重新跑一遍规则，自然就会出现多次传入同一个实例也会多次执行的表现。

符合你预期的场景示例 #

如果希望多次订阅同一个Observable实例时不会重复执行，只需要用多播类操作符把冷Observable转为热的、带缓存的流即可，比如：

import { of, concat } from 'rxjs';
import { shareReplay } from 'rxjs/operators';

const obs$ = of(1,2,3).pipe(shareReplay());
// 此时concat三次传入obs$，只会执行一次上游逻辑，后两次直接拿缓存结果
concat(obs$, obs$, obs$).subscribe(console.log);

这个时候的运行表现就会和你之前的预期一致。

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