createBehavioralMiddleware

gistfile1.txt

import BProgram from "./bp.js";

function createBehavioralMiddleware(threads) {
  return ({ dispatch, getState }) => {
    const bp = new BProgram();
    let pr = 1;
    bp.run();

    threads.forEach(thread => bp.addBThread(``, pr++, thread));
    bp.addBThread("dispatch", pr++, function*() {
      while (true) {
        yield {
          wait: [
            (event, payload) => {
              console.log("dispatching", {
                type: event,
                payload,
                bpThread: true
              });
              dispatch({ type: event, payload, bpThread: true });
              return true;
            }
          ]
        };
      }
    });

    return next => action => {
      // if it's a BP event continue reducers, otherwise return null
      // we only can run to the reducers and other middlewars
      // stuff coming "out" of the b-threads.
      if (action.bpThread) {
        return next(action);
      } else {
        bp.event(action.type, action.payload);
        return null;
      }
    };
  };
}

export default createBehavioralMiddleware;