RxJS异步上下文函数无法执行，求正确实现方式

你的代码存在两个核心问题，导致scan函数无法执行：

1. setTimeout不能被await直接等待 #

await仅能作用于Promise对象，而setTimeout返回的是定时器ID（数字类型），并非Promise。这会导致scan函数里的await setTimeout(5000)直接跳过等待逻辑，不过这不是函数不运行的主因，但必须修复。

2. 普通Subject会错过已发出的值 #

scanTasks$是普通Subject，当你调用queue$.next(options)后，scanTasks$.next(options)会立即发出值，但此时firstValueFrom(scanResult$)还未完成订阅（同步执行逻辑中，next先于订阅完成）。普通Subject不会保存已发出的值，新订阅者无法获取之前的事件，最终导致switchMap里的from(scan(options))永远不会被触发。

修复后的完整代码 #

第一步：修复scan函数的Promise封装

export async function scan(options: TaskOptions) {
  console.log("running scan");
  // 将setTimeout封装为Promise，实现真正的异步等待
  await new Promise(resolve => setTimeout(resolve, 5000));
  return true;
}

第二步：解决Subject值丢失问题（二选一即可）

方案A：使用ReplaySubject保存最近一次值

把scanTasks$替换为ReplaySubject(1)，它会自动保存最近的1个值，新订阅者能立即获取该值：

export const queue$ = new Subject<TaskOptions>();
// 用ReplaySubject替代普通Subject，保存最近1次发出的值
const scanTasks$ = new ReplaySubject<TaskOptions>(1);

export const scanResult$ = scanTasks$.pipe(
  switchMap((options) =>
    from(scan(options)).pipe(
      map(() => ({ error: undefined, success: true })),
      catchError((error: Error) => of({ error, success: false }))
    )
  )
);

queue$.subscribe((options) => {
  console.log("queue subscribe");
  scanTasks$.next(options);
});

// async context
queue$.next(options);
const result = await firstValueFrom(scanResult$);

方案B：调整订阅与触发的顺序

先创建firstValueFrom的Promise（此时已完成对scanResult$的订阅），再触发任务：

export const queue$ = new Subject<TaskOptions>();
const scanTasks$ = new Subject<TaskOptions>();

export const scanResult$ = scanTasks$.pipe(
  switchMap((options) =>
    from(scan(options)).pipe(
      map(() => ({ error: undefined, success: true })),
      catchError((error: Error) => of({ error, success: false }))
    )
  )
);

queue$.subscribe((options) => {
  console.log("queue subscribe");
  scanTasks$.next(options);
});

// async context
// 先准备好结果Promise（此时已完成订阅）
const resultPromise = firstValueFrom(scanResult$);
// 再触发任务
queue$.next(options);
// 等待结果
const result = await resultPromise;

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