如何在Observable未发射值时立即获取结果？现有方案疑问及优化

我希望在某个时刻获取Observable的值，即使它从未发射过，得到undefined/错误也可以接受，但当前代码会等待Observable发射值（逻辑使然）。

我有一个无法修改的服务：

export class MyService {
  private readonly isEnable$ = new ReplaySubject<boolean>(1)
    
  public init(isEnable: boolean) {
    this.isEnable$.next(isEnable);
  }

  public getFoo() {
    return this.isEnable$.pipe(
      map((isEnable: boolean) => isEnable ? foo : bar)
    )
  }
}

在我的代码中，我使用该服务获取信息，但存在无法初始化isEnable$的场景。此时执行以下代码不会有任何输出，这是正常现象：

this.myservice.getFoo().pipe(
  tap((value) => console.log(value))
).subscribe();

我希望无需等待isEnable$发射值，就能得到错误、undefined或空字符串。

我的临时解决方案如下：

race(
  this.myservice.getFoo(),
  of('').pipe(delay(1)),
).pipe(
  tap((value) => console.log(value)) //未初始化时得到''，初始化后得到正确值
).subscribe()

我有两个疑问：

1. 为什么第一个Observable的完成速度快于1ms？这种情况是否始终成立？
2. 有没有更好的实现方式？

解答 #

关于第一个疑问 #

• 当isEnable$已经通过init()初始化过，它作为ReplaySubject(1)会缓存最新值，订阅时会同步发射这个缓存值——同步代码会在当前事件循环立即执行，而delay(1)属于异步操作（会被放到下一个事件循环的宏任务队列中，至少等待1ms才执行），所以第一个Observable的发射速度必然远快于1ms，race操作符会优先选择它的输出。
• 这种情况是始终成立的：只要init()已经执行完成，ReplaySubject的缓存值会在订阅时同步触发，必然比任何带延迟的异步Observable先发射。但要注意，如果init()是在订阅之后异步执行（比如在1ms内完成），race会因为先触发了delay(1)的空值，而忽略后续isEnable$发射的有效值——这是你当前方案的潜在缺陷。

更好的实现方式 #

不需要依赖不确定的延迟时间，直接利用RxJS操作符实现“立即获取缓存值，无缓存则返回默认值”的逻辑，以下两种方式更可靠：

方式1：timeout + catchError

利用timeout(0)检测当前事件循环内是否有值发射，无值则触发超时并返回默认值：

import { timeout, catchError, take, of } from 'rxjs';

this.myservice.getFoo().pipe(
  take(1), // 仅获取当前时刻的第一个值（避免后续init触发重复输出）
  timeout({ first: 0 }), // 当前事件循环内无值则触发超时
  catchError(() => of(undefined)) // 超时后返回默认值，可替换为''或自定义错误
).subscribe(value => console.log(value));

方式2：race + 同步默认值

直接让目标Observable和同步发射默认值的Observable竞争：

import { race, of, take } from 'rxjs';

race(
  this.myservice.getFoo().pipe(take(1)),
  of(undefined) // 同步发射默认值
).subscribe(value => console.log(value));

逻辑说明：

• 若isEnable$有缓存值，第一个Observable会同步发射，race会优先选择它；
• 若isEnable$无缓存，第二个Observable会同步发射默认值，直接返回结果，不会等待后续的init()调用。

如果需要后续init()执行后仍能获取到值，只需移除take(1)，但此时无缓存时会先返回默认值，之后再返回init()的有效值——根据你的需求，若只需要“当前时刻”的结果，take(1)是必要的。

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