如何在Angular单元测试中对Rxjs的take等操作符进行spy监听？

核心错误原因 #

首先要明确你测试思路的根本性误区：
RxJS 管道中操作符的调用分为两个阶段：

1. 构造阶段：调用.pipe()方法时，会依次执行你传入的select(xxx)、filter(xxx)、take(1)这些操作符函数，返回对应的操作符实例组装成管道链。这个阶段不管流后续有没有数据，所有操作符函数都会被执行。
2. 运行阶段：流有数据传递时，数据会依次经过组装好的操作符实例处理。

你要验证的是「filter 过滤掉无效 profile 后，数据不会传递到 take 操作符的运行逻辑」，而不是「take 函数不会被调用」——因为 take 函数在构造阶段必然会被调用，你的原始测试目标从逻辑上就不成立。

此外你遇到的 spy 报错原因：

• take is not declared writable or has no setter：ES 模块导出的成员默认是不可写常量，RxJS v6+ 之后的操作符都是只读导出，普通spyOn无法直接覆写。
• TypeError: fn is not a function：take不是 get/set 类型的访问器属性，spyOnProperty无法正确获取和替换它的实现，你强制返回的自定义 spy 不符合操作符的函数签名，管道执行时就会报错。

推荐方案：测试实际行为（无需 spy 操作符） #

单元测试应该聚焦输出行为而非内部实现，你要验证的是「profile 无效时路由不会被解析」，本质就是验证 resolve 方法返回的 Observable 不会发出有效值、也不会完成，直接测试这个行为即可：

it('should not resolve the route if profile is not valid', (done) => {
  // 模拟返回无效的profile
  mockStore.overrideSelector(selectLoggedUserProfile, null);
  let resolverEmitted = false;

  service.resolve(route, null).subscribe({
    next: () => {
      resolverEmitted = true;
      done.fail('无效profile下Resolver不应该发出值');
    },
    complete: () => {
      resolverEmitted = true;
      done.fail('无效profile下Resolver不应该完成流');
    }
  });

  // 等待100ms确认流无输出，超时时间可根据实际情况调整
  setTimeout(() => {
    expect(resolverEmitted).toBeFalse();
    done();
  }, 100);
});

更严谨的流行为测试方案 #

可以使用 RxJS 官方测试工具TestScheduler精准验证流的输出，无需依赖超时判断：

import { TestScheduler } from 'rxjs/testing';

it('should not pass value to take when profile is invalid', () => {
  const testScheduler = new TestScheduler((actual, expected) => {
    expect(actual).toEqual(expected);
  });

  testScheduler.run(({ cold, expectObservable }) => {
    // 模拟store持续返回无效profile
    const mockStoreStream$ = cold('a-b-c-d', { a: null, b: null, c: {id: null}, d: undefined });
    spyOn(mockStore, 'pipe').and.returnValue(mockStoreStream$);

    const result$ = service.resolve(route, null);
    // 期望结果：流全程没有任何输出和完成事件
    expectObservable(result$).toBe('--------');
  });
});

特殊场景：确实需要 spy RxJS 操作符的方法 #

如果你的场景必须 spy 操作符实现，可以通过模块模拟的方式绕过只读限制，以 Jasmine 为例：

// 测试文件最顶部，所有import之前声明模块模拟
jasmine.mock('rxjs/operators', () => {
  const originalOperators = jasmine.requireActual('rxjs/operators');
  return {
    ...originalOperators,
    take: jasmine.createSpy('take').and.callFake(originalOperators.take)
  };
});

// 后续正常导入操作符使用
import * as rxjsOperators from 'rxjs/operators';

注意这种方法耦合了内部实现，只要你调整了管道中操作符的顺序、替换了操作符，测试就会失效，不推荐常规场景使用。

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