rx react

// Rx
function createStore(actionsToReducers, initialState = {}) {
  let dispatch;
  const action$ = $.create(observer => {
    dispatch = action => observer.onNext(action)
  });
  
  const reducer$ = actionsToReducers(action$);
  const state$ = reducer$
    .scan((state, [scope, reducer]) =>
      ({ ...state, [scope]: reducer(state[scope]) }), initialState)
    .startWith(initialState)
    .publishReplay(1)
    .refCount();
    
  return {state$, dispatch};
}

// xstream
function createStore(actionsToReducers, initialState = {}) {
  let dispatch;
  const action$ = xs.create({
    start(listener) {
      dispatch = action => listener.next(action)
    }
  });
  
  const reducer$ = actionsToReducers(action$);
  const state$ = reducer$
    .fold((state, [scope, reducer]) =>
      ({ ...state, [scope]: reducer(state[scope]) }), initialState);
    
  return {state$, dispatch};
}

can you share how actionsToReducers function will look like?