RxJS中toPromise()替换为lastValueFrom()报EmptyError的最优解决方案

问题根因 #

你的createMyRecord方法返回的Observable最终通过mergeMap(() => EMPTY)结束，EMPTY不会发出任何值就直接完成。RxJS 7+的lastValueFrom要求Observable至少发出一个值，否则就会抛出EmptyError；而已废弃的toPromise对于空Observable会直接返回undefined，不会报错，这就是你替换后出现报错的核心原因。

更优解决方案 #

有两个更简洁的方案可以避免手写catch判断：

方案1：修改Observable定义，适配空序列场景 #

如果你不需要createMyRecord返回实际业务值，只需要标记任务执行完成，可以在Observable管道末尾添加defaultIfEmpty操作符，主动给空序列补一个默认返回值：

import { defaultIfEmpty } from 'rxjs';

createMyRecord(): Observable<myRecord | undefined> {
  return of(TEMPLATE_DB).pipe(
    mergeMap((template) => doTask(template)),
    mergeMap(() => EMPTY),
    defaultIfEmpty(undefined) // 空序列完成前主动发出一个undefined
  );
}

修改后直接调用即可，不需要额外加捕获逻辑：

await lastValueFrom(createMyRecord());

方案2：调用时传入默认值（无需修改原有方法） #

如果你不想改动createMyRecord的现有实现，可以直接使用lastValueFrom的第二个配置参数传入默认值，空序列会自动返回该默认值，不会抛出异常：

await lastValueFrom(createMyRecord(), { defaultValue: undefined });

这两种方案都比手动捕获EmptyError的写法更简洁，也更符合RxJS的API设计规范。

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