ngrx/effects使用jasmine-marble进行单元测试

import { TestBed } from '@angular/core/testing';
import { provideMockActions } from '@ngrx/effects/testing';
import { Observable, of } from 'rxjs';
import { TestScheduler } from 'rxjs/testing';

import { MyEffects } from './my.effects';
import { MyService } from './my.service';
import { LoadData, LoadDataSuccess } from './my.actions';

describe('MyEffects', () => {
  let effects: MyEffects;
  let actions$: Observable<any>;
  let scheduler: TestScheduler;

  beforeEach(() => {
    TestBed.configureTestingModule({
      providers: [
        MyEffects,
        provideMockActions(() => actions$),
        {
          provide: MyService,
          useValue: jasmine.createSpyObj('MyService', ['getData'])
        }
      ]
    });

    effects = TestBed.inject(MyEffects);
    actions$ = TestBed.inject(Actions);
    scheduler = new TestScheduler((actual, expected) => {
      expect(actual).toEqual(expected);
    });
  });

  it('should load data successfully', () => {
    const service = TestBed.inject(MyService);
    const data = { id: 1, name: 'John' };
    const action = new LoadData();
    const completion = new LoadDataSuccess(data);

    scheduler.run(({ cold, hot, expectObservable }) => {
      actions$ = hot('-a', { a: action });
      const response = cold('-b|', { b: data });
      service.getData.and.returnValue(response);

      expectObservable(effects.loadData$).toBe('--c', { c: completion });
    });
  });
});