如何测试使用依赖项注射服务事件的NGRX效应

Question

我有以下效果，它使用了来自Angulars依赖注入提供的平台服务的可观察源。

public resume$ = createEffect(() => {
  return this.platformService.resume().pipe(mapTo(PlatformActions.appResumed()));
});

constructor(private platformService: PlatformService) {
}

这确实很好，但是我真的不知道如何优雅地测试它。通常，我们尝试尽可能地设置测试模块。例如，

describe('PlatformEffects', () => {
  let effects: PlatformEffects;
  let platformServiceSpy: SpyObj<PlatformService>;

  beforeEach(() => {
    platformServiceSpy = jasmine.createSpyObj({
      resume: EMPTY
    });

    TestBed.configureTestingModule({
      providers: [
        PlatformEffects,
        {
          provide: PlatformService,
          useValue: platformServiceSpy
        }
      ]
    });

    effects = TestBed.inject(PlatformEffects);
  });

  it('should be created', () => {
    expect(effects).toBeTruthy();
  });

  describe('resume$', () => {
    it('dispatches appResumed action on resume event', (done) => {
      // AAA: This test should setup the response from the platformService so the arrange setup is coupled in the test.
    });
  });
});

可悲的是，这似乎不起作用，因为效果是在构造函数中创建的，因此我的事件流始终是空的，即使我在间谍中覆盖简历响应，也不会触发效果。

现在，我可以在the each（例如（UNDEFINED））中设置一个默认值，但是它在测试中并没有真正耦合，我无法使用AAA模式。

另一方面，我可能每次都可以创建一个新的效果实例，但这似乎有点过分？

有更好的方法吗？ NGRX在动作流方面确实很好地解决了它，我想知道使用DI源是否有类似的效果解决方案。

Answer 1

有关更多信息，请参见，

it('fetch$ dispatches a success action', () => {

    // 

Answer 2

我尝试了更多的尝试，并认为操作流可能只是一个主题，我可以为自己的服务方法做同样的事情：

describe('PlatformEffects', () => {
  let effects: PlatformEffects;
  let platformServiceSpy: SpyObj<PlatformService>;

  let resumeSubject: ReplaySubject<any>;

  beforeEach(() => {
    // create new subject that can be used as an event emitter
    resumeSubject = new ReplaySubject<any>();

    platformServiceSpy = jasmine.createSpyObj({
      resume: resumeSubject.asObservable()
    });

    TestBed.configureTestingModule({
      providers: [
        PlatformEffects,
        {
          provide: PlatformService,
          useValue: platformServiceSpy
        }
      ]
    });

    effects = TestBed.inject(PlatformEffects);
  });

  it('should be created', () => {
    expect(effects).toBeTruthy();
  });

  describe('resume
这对这种情况有效，但是一旦我尝试使用返回返回a的服务方法做同样的事情承诺此解决方案不再起作用。
, () => {
    it('dispatches appResumed action on resume event', (done) => {
      // emit new test string in resume subject
      resumeSubject.next('test');

      effects.resume$.subscribe((res) => {
        expect(res).toEqual(PlatformActions.appResumed());
        done();
      });
    });
  });
});

这对这种情况有效，但是一旦我尝试使用返回返回a的服务方法做同样的事情承诺此解决方案不再起作用。