如何在ngRX效果中测试forkJoin

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

import { MyEffects } from './my.effects';
import { MyService } from './my.service';
import { MyAction, MySuccessAction } from './my.actions';

describe('MyEffects', () => {
  let runner: EffectsRunner;
  let myEffects: MyEffects;
  let myService: MyService;
  let actions$: Observable<any>;

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

    runner = TestBed.get(EffectsRunner);
    myEffects = TestBed.get(MyEffects);
    myService = TestBed.get(MyService);
    actions$ = runner.actions;
  });

  it('should call forkJoin and dispatch success action', () => {
    const data1 = { id: 1, name: 'John' };
    const data2 = { id: 2, name: 'Jane' };
    const expectedAction = new MySuccessAction([data1, data2]);

    myService.getData.and.returnValue(forkJoin([of(data1), of(data2)]));

    runner.queue(new MyAction());

    myEffects.getData$.subscribe(result => {
      expect(result).toEqual(expectedAction);
    });
  });
});