3

2 番目の NGRX エフェクト (nrwl/nx dataPersistence 表記を使用) が与えられ、2 番目のエフェクトは によって最初のエフェクトにバインドされtakeUntilます。

@Injectable()
export class ModuleEffects {

  @Effect() effectOne$ = this.dataPersistence.fetch(ModuleActionTypes.ActionOne, {
    run: (action: ActionOne, state: ModulePartialState) => {
     return new SomeReturnAction();
    },
  });

  @Effect() effectTwo$ = this.dataPersistence.fetch(ModuleActionTypes.ActionTwo, {
    run: (action: ActionTwo, state: ModulePartialState) => {
      return this.service.apiCall().pipe(
        takeUntil(this.effectOne$),
        map(result => new SomeResultAction(result))
      );
    },
  });

意図は、effectOne$ が発行されるとすぐに UI 入力による SomeResultAction の発行を停止することです (これは正常に動作します)。

私は今、jasmine-marbles ライブラリを使用してこれらの効果をテストしようとしています:

    it('should stop emitting after effectOne$ has emitted', () => {
      const action = new ActionTwo();
      const interruptingAction = new ActionOne();
      const outcome = new SomeResultAction(mockedResult);
      actions = hot('        -a--a-ia|', { a: action, i: interruptingAction });
      const expected = cold('-b--b--b|', { b: outcome });

      expect(effects.effectTwo$).toBeObservable(expected);
    });

ディスパッチされたexpected後にオブザーバブルが完了することを期待していても、このテストは成功します。interruptingAction

4

0 に答える 0