logOutEpic.js

import { combineEpics } from 'redux-observables';

export function logOutEpic(actions, getState) {
  return actions.ofType(....)
}

export function otherEpic(actions, getState) {
  return actions.ofType(....)
}

export default combineEpics(logOutEpic, otherEpic);

ReactRx.js

import { ActionsObservable } from 'redux-observale/lib/ActionsObservable';

import rootEpic from './epics';
const flux = new Reactor({ /*...*/ });


const input$ = new Subject();
const actions$ = new ActionsObservable(input$);
const epic$ = new Subject();
 epic$
    ::switchMap(epic => epic(action$, () => flux.evaluate([])))
    .subscribe(({ type: action, payload }) => flux.dispatch(action, payload)));

    // Setup initial root epic
    epic$.next(rootEpic);
    
export function dispatch(action, payload) {
  input$.next({ type: action, payload });
  flux.dispatch(action, payload);
})

export default flux;