ngrx_testing_state_effect.spec.ts

describe('app state effects', () => {
  it('can fetch data with args from state', () => {
    const source = cold('a', { a: { type: actions.DATA_WITH_STATE_FETCH } });
    const storeStub = getStoreStub();

    const effect = new AppStateEffect(new Actions(source), storeStub);

    const expected = cold('a', { a: { type: actions.DATA_WITH_STATE_FETCH_SUCCESS } });
    expect(effect.fetchDataWithState$).toBeObservable(expected);
  });

  function getStoreStub(): any {
    const initialAppState = reducer(undefined, { type: 'INIT_ACTION' });
    return {
      select: (selector) => Observable.of(selector(initialAppState))
    };
  }
});