为何RxJS中startWith与lastValueFrom配合使用时未按预期触发？

问题场景 #

我尝试用lastValueFrom将包含startWith操作符的Observable转换为Promise，代码如下：

const obs = timer(1000).pipe(
  map(() => `First Value!`),
  startWith('But StartWith this')
);

lastValueFrom(obs).then(console.log);

输出结果为：

First Value!

但直接订阅该Observable时，输出符合预期：

obs.subscribe(console.log);

输出：

But StartWith this
First Value!

补充场景：以下代码永远无法resolve：

const obs = new Subject().asObservable().pipe(startWith('startWith'));
lastValueFrom(obs).then(console.log);

问题原因 #

1. lastValueFrom的核心行为是等待Observable完成，返回其最后一次发射的值。
   第一个例子中，timer(1000)是会自动完成的Observable：先通过startWith发射初始值，1秒后发射目标值，随后Observable完成，因此lastValueFrom取到的是最后发射的First Value!，这是该方法的正常逻辑，并非异常。
2. 补充例子中的Subject转换而来的Observable不会自动完成，startWith发射初始值后，Observable始终处于活跃状态，lastValueFrom会一直等待其完成，因此永远不会resolve。

解决方案 #

根据需求不同，可采用以下几种处理方式：

• 若需要获取Observable完成时的最后值：
  确保Observable能正常完成。对于不会自动完成的Observable（如Subject），可手动触发完成，或通过操作符触发完成：

  const subj = new Subject();
  const obs = subj.asObservable().pipe(startWith('startWith'));
  // 手动触发完成
  subj.complete();
  lastValueFrom(obs).then(console.log); // 输出 startWith
  

• 若需要获取startWith的初始值：
  使用take(1)操作符限制只取第一个发射的值，再配合lastValueFrom：

  const obs = timer(1000).pipe(
    map(() => `First Value!`),
    startWith('But StartWith this'),
    take(1)
  );
  lastValueFrom(obs).then(console.log); // 输出 But StartWith this
  

• 若Observable无需完成，要获取最新值：
  推荐使用BehaviorSubject替代Subject + startWith，它会保存当前最新值，订阅时立即返回；或结合firstValueFrom与shareReplay(1)：

  // 使用BehaviorSubject
  const subj = new BehaviorSubject('startWith');
  firstValueFrom(subj.asObservable()).then(console.log); // 输出 startWith
  

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