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