Angular/RxJS 6：如何单元测试next()触发的代码抛出异常

我明白你遇到的困扰了——RxJS 6 对同步错误的处理逻辑做了关键调整，直接导致你之前的测试方式失效了。

问题根源 #

在 RxJS 5 中，subscribe 的 next 回调里同步抛出的异常会直接冒泡到调用 next() 的代码上下文，所以你的测试能通过 expect(() => ...).toThrow() 捕获到异常。但从 RxJS 6 开始，这类异常会被 RxJS 自动捕获，并转化为 Observable 的错误通知，不会再直接向外抛出。这就是你测试突然失效的核心原因。

解决方案 #

你需要调整测试逻辑，改为监听 Observable 的错误通道来验证异常，下面是两种可行的实现方式：

方式一：在测试中订阅错误通知（推荐）

利用 Angular 测试工具的 fakeAsync 和 tick 来处理同步的 RxJS 操作，直接捕获错误通知：

it('should throw error for invalid message', fakeAsync(() => {
  let caughtError: Error | undefined;

  // 手动订阅Subject的错误通道，捕获抛出的异常
  myComponent.mySubject.subscribe({
    error: (err) => caughtError = err as Error
  });

  // 触发Subject的next方法
  myComponent.mySubject.next({message: 'invalid'});
  tick(); // 强制触发所有同步的RxJS流操作

  // 断言错误信息是否符合预期
  expect(caughtError).toBeDefined();
  expect(caughtError?.message).toBe('invalid is not an accepted message');
}));

方式二：给组件的订阅添加错误回调（可选）

如果你希望组件本身也处理这类错误，可以先修改组件的订阅逻辑，添加错误回调：

// 组件代码调整
ngOnInit(){
  this.mySubject.subscribe(
    obj => this._doSomething(obj),
    (err) => {
      // 这里可以添加组件内的错误处理逻辑，比如日志或用户提示
      console.error('处理消息时发生错误:', err);
    }
  )
}

之后测试逻辑和方式一一致，通过监听错误通道来验证异常是否正确抛出。

补充说明 #

RxJS 6 的这个改动其实是更贴合 Observable 规范的——错误应该通过 Observable 的 error 通知传递，而不是直接抛出到流外部。调整测试来适配这个规范，也能让你的测试更符合 RxJS 的设计思想。

内容的提问来源于stack exchange，提问作者M'sieur Toph'