Angular服务Jasmine单元测试问题：results.next未触发

核心问题 #

你的测试无法触发results.next()，主要源于三个关键问题：

1. 服务类代码的隐性错误：_funProcessing方法里直接写results.next()，没通过this引用类属性，导致实际调用时找不到服务实例的results Subject。
2. 测试未模拟WebSocket响应：getResponse发送查询后，需要websocketSubject主动发消息才能触发_funProcessing，你的测试完全没模拟这一步。
3. 测试流程逻辑混乱：断言在异步流程启动前同步执行，而且你注释掉了service.getResponse(1)的调用，等于没启动整个业务流程。

先修复服务类的自身问题 #

class MyServiceClass {
  results = new Subject<MyType>();
  signalEnd = new Subject<void>();
  private websocketSubject: Subject<any>; // 补充定义，实际项目中可能是注入或初始化的

  constructor() {
    // 修正：绑定this上下文，避免函数调用时丢失实例指向
    this.websocketSubject.subscribe((res) => this._funProcessing(res));
  }

  private _funProcessing(responseFromSocket: MyType) {
    // 修正：通过this访问类的results属性
    if (responseFromSocket === likeTheResponse) {
      this.results.next(responseFromSocket);
    }
  }

  getResponse(query: any) {
    this.websocketSubject.next(query); // 通常WebSocket Subject用next发送消息，根据实际调整
    return this.results;
  }
}

正确的单元测试代码 #

需要模拟WebSocket Subject，手动触发消息，确保异步流程走完后再断言：

import { TestBed } from '@angular/core/testing';
import { MyServiceClass } from './my-service';
import { Subject } from 'rxjs';

describe('MyServiceClass', () => {
  let service: MyServiceClass;
  let mockWebSocketSubject: Subject<any>;

  beforeEach(() => {
    mockWebSocketSubject = new Subject<any>();
    
    TestBed.configureTestingModule({
      providers: [MyServiceClass]
    });
    service = TestBed.inject(MyServiceClass);
    // 替换服务内部的websocketSubject为模拟对象（私有属性用反射访问）
    (service as any).websocketSubject = mockWebSocketSubject;
  });

  it('should process a message and emit results', (done) => {
    const testQuery = 1;
    const mockResponse = { index: 1 }; // 符合likeTheResponse的测试数据

    // 订阅results，等待异步触发
    service.results.subscribe((value) => {
      expect(value.index).toEqual(1);
      done(); // 通知测试异步流程完成
    });

    // 启动业务流程：发送查询
    service.getResponse(testQuery);
    // 手动触发WebSocket响应，模拟后端返回消息
    mockWebSocketSubject.next(mockResponse);
  });
});

关键调整说明 #

• 绑定this上下文：构造函数里用箭头函数包裹_funProcessing，确保函数调用时this始终指向服务实例，能正确访问this.results。
• 模拟WebSocket Subject：测试中完全控制WebSocket的消息发送，确保能触发_funProcessing的逻辑分支。
• 异步测试规范写法：用done回调在results的订阅回调里执行断言，保证只有异步流程完成后才验证结果。
• 修正属性引用：所有类属性访问必须加this.，避免误指向全局变量。

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