angular - RxJS - 单元测试 mergeMap 内部 Observable

Question

我有以下代码:

  createAsset(asset: Asset): void {
    this._assetsService.uploadFile()
    .pipe(
      mergeMap(_ => this._assetsService.createAsset({
        ...asset,
        extension: 'png'
      })),
      take(1)
    )
    .subscribe(_ => {}, _ => console.error(_));
  }

而且我想确保无论何时调用此函数，它都会使用正确的参数调用 createAsset。

我确实使用 Karma 和 Jasmine 编写了一个 UT:

it('...', async (async () => {
    const assetsService = TestBed.inject(AssetsService);
    const uploadSpy = spyOn(assetsService, 'uploadFile').and.returnValue(of());
    const createSpy = spyOn(assetsService, 'createAsset').and.returnValue(of());

    const extension = 'png';

    const asset = {
      name: 'name',
      extension: null
    };

    component.createAsset(asset);

    await fixture.whenStable();
    expect(uploadSpy).toHaveBeenCalled();
    expect(createSpy).toHaveBeenCalledWith({...asset, extension}); // Error : This is never called
  }));

永远不会调用 mergeMap createSpy 的内部可观察对象。有什么我想念的吗？

Answer 1

 const uploadSpy = spyOn(assetsService, 'uploadFile').and.returnValue(of());

问题在于使用 Observable<void> 的模拟只需用 void 以外的任何内容替换它解决了这个问题。