The call operator

[wxnet2013]

import rxloop, { call } from '@rxloop/core';
import { map } from 'rxjs/operators';

const counter = {
  name: 'counter',
  state: 0,
  reducers: {
    increment(state) {
      return {
        ...state,
        counter: state.counter + 1
      };
    },
  },
  epics: {
    getData(action$) {
      return action$.pipe(
        call(async (action) => {
          return {};
        }),
        map((data) => {
          return {
            data,
            type: 'increment',
          };
        }),
      );
    }
  },
};

store.model(counter);

store.stream('counter').subscribe((state) => {
  if (state.error) {
    console.log( state.error.epic );
    return;
  }
  // setState(state);
});