rxjs.test.js

test("connectModel epics", () => {
  const initialState = {
    value: "initial",
    loading: null
  };

  const updaters = {};

  const epics = {
    loadValue: {
      actionUpdater: () => state => Object.assign({}, state, { loading: true }),
      successUpdater: value => state =>
        Object.assign({}, state, { loading: false, value }),
      errorUpdater: () => () => null,
      service: () => Promise.resolve({ data: "new promised value" })
    }
  };

  const connectedModel = connectModel({ initialState, updaters, epics });

  const expectationPromise = connectedModel.stateStream
    .skip(2)
    .take(1)
    .forEach(state => {
      expect(state).toEqual({ value: "new promised value", loading: false });
    });

  connectedModel.actions.loadValue();

  return expectationPromise;
});